Package org.jgroups.tests

Class ParseMessagesFields

java.lang.Object

org.jgroups.tests.ParseMessages

org.jgroups.tests.ParseMessagesFields

public class ParseMessagesFields
extends ParseMessages

While investigating network errors, we would like to look for timestamp and JGroups data. But when needed, we need to add more fields like source and destination ports. Example: tshark -q -i lo0 -Tfields -e frame.time_epoch -e udp.srcport -e udp.dstport -e data udp and port 9090 Run: ParseMessages -instance org.jgroups.tests.ParseMessagesFields -Dfields="frame.time_epoch,udp.srcport,udp.dstport"

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ParseMessagesFields.BinaryToAsciiWithFieldsInputStream

Nested classes/interfaces inherited from class org.jgroups.tests.ParseMessages

ParseMessages.BinaryToAsciiInputStream, ParseMessages.InnerParseMessages

Field Summary

Fields

Modifier and Type	Field	Description
private static java.lang.String[]	fields
private static java.time.format.DateTimeFormatter	TIME_EPOCH_DATE_TIME_FORMATTER
private static java.time.ZoneId	ZONE_ID

Fields inherited from class org.jgroups.tests.ParseMessages

GMS_ID, show_views

Constructor Summary

Constructors

Constructor	Description
ParseMessagesFields()

Method Summary

Modifier and Type	Method	Description
protected java.io.InputStream	createInputStream(java.io.InputStream in)
void	parse(java.io.InputStream in, java.util.function.BiConsumer<java.lang.Short,Message> msg_consumer, java.util.function.BiConsumer<java.lang.Short,MessageBatch> batch_consumer, boolean tcp)
void	parseWithFields(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 org.jgroups.tests.ParseMessages

getView, help, main, parse, parseDiscoveryResponse, readMappings

Methods inherited from class java.lang.Object

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

Field Detail

TIME_EPOCH_DATE_TIME_FORMATTER

private static final java.time.format.DateTimeFormatter TIME_EPOCH_DATE_TIME_FORMATTER

ZONE_ID

private static final java.time.ZoneId ZONE_ID

fields

private static java.lang.String[] fields

Constructor Detail

ParseMessagesFields

public ParseMessagesFields()

Method Detail

createInputStream

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

Overrides:

createInputStream in class ParseMessages

parse

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

Overrides:

parse in class ParseMessages

parseWithFields

public void parseWithFields(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)