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 String[]	fields
private static final DateTimeFormatter	TIME_EPOCH_DATE_TIME_FORMATTER
private static final 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 InputStream	createInputStream(InputStream in)
void	parse(InputStream in, BiConsumer<Short,Message> msg_consumer, BiConsumer<Short,MessageBatch> batch_consumer, Consumer<GossipData> gossip_consumer, boolean tcp, boolean gossip)
void	parseWithFields(InputStream input, BiConsumer<Short,Message> msg_consumer, BiConsumer<Short,MessageBatch> batch_consumer, boolean tcp, boolean gossip)

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 Details

TIME_EPOCH_DATE_TIME_FORMATTER

private static final DateTimeFormatter TIME_EPOCH_DATE_TIME_FORMATTER

ZONE_ID

private static final ZoneId ZONE_ID

fields

private static String[] fields

Constructor Details

ParseMessagesFields

public ParseMessagesFields()

Method Details

createInputStream

protected InputStream createInputStream(InputStream in)

Overrides:

createInputStream in class ParseMessages

parse

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

Overrides:

parse in class ParseMessages

parseWithFields

public void parseWithFields(InputStream input,
 BiConsumer<Short,Message> msg_consumer,
 BiConsumer<Short,MessageBatch> batch_consumer,
 boolean tcp,
 boolean gossip)