Package org.jgroups.tests

Class ParseMessages.InnerParseMessages

java.lang.Object

org.jgroups.tests.ParseMessages.InnerParseMessages

Enclosing class:

ParseMessages

protected static class ParseMessages.InnerParseMessages
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final BiConsumer<Short,MessageBatch>	batch_consumer
private final boolean	binary_to_ascii
(package private) final Consumer<GossipData>	gossip_consumer
(package private) final BiConsumer<Short,Message>	msg_consumer
private final ParseMessages	parseMessages

Constructor Summary

Constructors

Constructor	Description
InnerParseMessages(boolean print_vers, boolean binary_to_ascii, boolean parse_discovery_responses, String instance)

Method Summary

Modifier and Type	Method	Description
InputStream	createInputStream(InputStream in)
void	parse(InputStream input, BiConsumer<Short,Message> msg_consumer, BiConsumer<Short,MessageBatch> batch_consumer, Consumer<GossipData> gossip_consumer, boolean tcp, boolean gossip)

Methods inherited from class java.lang.Object

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

Field Details

binary_to_ascii

private final boolean binary_to_ascii

msg_consumer

final BiConsumer<Short,Message> msg_consumer

batch_consumer

final BiConsumer<Short,MessageBatch> batch_consumer

gossip_consumer

final Consumer<GossipData> gossip_consumer

parseMessages

private final ParseMessages parseMessages

Constructor Details

InnerParseMessages

public InnerParseMessages(boolean print_vers,
 boolean binary_to_ascii,
 boolean parse_discovery_responses,
 String instance)
                   throws Exception

Throws:

Exception

Method Details

createInputStream

public InputStream createInputStream(InputStream in)

parse

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

Throws:

FileNotFoundException