public class ActiveMQPacketParser extends Object implements PacketParser
Constructor and Description |
---|
ActiveMQPacketParser() |
Modifier and Type | Method and Description |
---|---|
String |
getGroup() |
DiscoveryEvent |
processPacket(byte[] packet,
int offset,
int length)
Process in incoming event packet and create a DiscoveryEvent from the data.
|
void |
setGroup(String group)
Sets the multicast group that the parent agent is assigned to.
|
public String getGroup()
getGroup
in interface PacketParser
public void setGroup(String group)
PacketParser
setGroup
in interface PacketParser
group
- the multicast group that this parser's parent agent resides in./public DiscoveryEvent processPacket(byte[] packet, int offset, int length)
PacketParser
processPacket
in interface PacketParser
packet
- the new data packet to process.offset
- the offset into the data buffer to start at.length
- the length of the data packet contained in the buffer.Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.