Package org.jgroups.tests

Class ParseMessages

java.lang.Object

org.jgroups.tests.ParseMessages

Direct Known Subclasses:

ParseMessagesFields

public class ParseMessages
extends Object

Parses messages out of a captured file and writes them to stdout

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	ParseMessages.BinaryToAsciiInputStream
protected static class	ParseMessages.InnerParseMessages

Field Summary

Fields

Modifier and Type	Field	Description
protected static final short	GMS_ID
protected static boolean	show_views

Constructor Summary

Constructors

Constructor	Description
ParseMessages()

Method Summary

Modifier and Type	Method	Description
protected InputStream	createInputStream(InputStream in)
protected static View	getView(Message msg)
protected static void	help()
static void	main(String[] args)
static void	parse(byte[] buf, int offset, int length, BiConsumer<Short,Message> msg_consumer, BiConsumer<Short,MessageBatch> batch_consumer, Consumer<GossipData> gossip_consumer, boolean tcp, boolean gossip)
void	parse(InputStream in, BiConsumer<Short,Message> msg_consumer, BiConsumer<Short,MessageBatch> batch_consumer, Consumer<GossipData> gossip_consumer, boolean tcp, boolean gossip)
protected static void	parseDiscoveryResponse(Message msg)
protected static void	readMappings(String filename)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

GMS_ID

protected static final short GMS_ID

show_views

protected static boolean show_views

Constructor Details

ParseMessages

public ParseMessages()

Method Details

parse

public static void parse(byte[] buf,
 int offset,
 int length,
 BiConsumer<Short,Message> msg_consumer,
 BiConsumer<Short,MessageBatch> batch_consumer,
 Consumer<GossipData> gossip_consumer,
 boolean tcp,
 boolean gossip)

parse

public void parse(InputStream in,
 BiConsumer<Short,Message> msg_consumer,
 BiConsumer<Short,MessageBatch> batch_consumer,
 Consumer<GossipData> gossip_consumer,
 boolean tcp,
 boolean gossip)
           throws FileNotFoundException

Throws:

FileNotFoundException

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

createInputStream

protected InputStream createInputStream(InputStream in)

parseDiscoveryResponse

protected static void parseDiscoveryResponse(Message msg)
                                      throws Exception

Throws:

Exception

getView

protected static View getView(Message msg)

help

protected static void help()

readMappings

protected static void readMappings(String filename)
                            throws IOException

Throws:

IOException