Package org.jgroups.tests

Class ParseMessages.InnerParseMessages

java.lang.Object

org.jgroups.tests.ParseMessages.InnerParseMessages

Enclosing class:

ParseMessages

static class ParseMessages.InnerParseMessages
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
(package private) java.util.function.BiConsumer<java.lang.Short,MessageBatch>	batch_consumer
private boolean	binary_to_ascii
(package private) java.util.function.BiConsumer<java.lang.Short,Message>	msg_consumer
private ParseMessages	parseMessages

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
java.io.InputStream	createInputStream(java.io.InputStream in)
void	parse(java.io.InputStream input, java.util.function.BiConsumer<java.lang.Short,Message> msg_consumer, java.util.function.BiConsumer<java.lang.Short,MessageBatch> batch_consumer, boolean tcp)

Methods inherited from class java.lang.Object

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

Field Detail

binary_to_ascii

private final boolean binary_to_ascii

msg_consumer

final java.util.function.BiConsumer<java.lang.Short,Message> msg_consumer

batch_consumer

final java.util.function.BiConsumer<java.lang.Short,MessageBatch> batch_consumer

parseMessages

private final ParseMessages parseMessages

Constructor Detail

InnerParseMessages

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

Throws:

java.lang.Exception

Method Detail

createInputStream

public java.io.InputStream createInputStream(java.io.InputStream in)

parse

public void parse(java.io.InputStream input,
                  java.util.function.BiConsumer<java.lang.Short,Message> msg_consumer,
                  java.util.function.BiConsumer<java.lang.Short,MessageBatch> batch_consumer,
                  boolean tcp)
           throws java.io.FileNotFoundException

Throws:

java.io.FileNotFoundException