Package org.apache.qpid.jms.provider.discovery.multicast.parsers

Class ActiveMQPacketParser

java.lang.Object

org.apache.qpid.jms.provider.discovery.multicast.parsers.ActiveMQPacketParser

All Implemented Interfaces:

PacketParser

public class ActiveMQPacketParser
extends Object
implements PacketParser

Parser instance for ActiveMQ multicast discovery processing.

Constructor Summary

Constructors

Constructor	Description
ActiveMQPacketParser()

Method Summary

Modifier and Type	Method	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.

Methods inherited from class java.lang.Object

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

Constructor Detail

ActiveMQPacketParser

public ActiveMQPacketParser()

Method Detail

getGroup

public String getGroup()

Specified by:

getGroup in interface PacketParser

Returns:

the multicast group assignment for this parser.

setGroup

public void setGroup(String group)

Description copied from interface: PacketParser

Sets the multicast group that the parent agent is assigned to. This can be used in some cases to parse discovery messages.

Specified by:

setGroup in interface PacketParser

Parameters:

group - the multicast group that this parser's parent agent resides in./

processPacket

public DiscoveryEvent processPacket(byte[] packet,
                                    int offset,
                                    int length)

Description copied from interface: PacketParser

Process in incoming event packet and create a DiscoveryEvent from the data.

Specified by:

processPacket in interface PacketParser

Parameters:

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.

Returns:

a new DiscoveryEvent created from pocessing the incoming data.