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

Class ActiveMQPacketParser

  • All Implemented Interfaces:
    PacketParser
    public class ActiveMQPacketParser
extends java.lang.Object
implements PacketParser
    Parser instance for ActiveMQ multicast discovery processing.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.lang.String getGroup()  
      DiscoveryEvent processPacket​(byte[] packet, int offset, int length)
      Process in incoming event packet and create a DiscoveryEvent from the data.
      void setGroup​(java.lang.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 java.lang.String getGroup()
        Specified by:
        getGroup in interface PacketParser
        Returns:
        the multicast group assignment for this parser.

      • setGroup

        public void setGroup​(java.lang.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.