Package org.apache.activemq.transport.amqp

Interface AmqpProtocolConverter

  • All Known Implementing Classes:
    AmqpConnection, AmqpProtocolDiscriminator
    public interface AmqpProtocolConverter
    Interface that defines the API for any AMQP protocol converter ised to map AMQP mechanics to ActiveMQ and back.

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      long keepAlive()
      Perform any keep alive processing for the connection such as sending empty frames or closing connections due to remote end being inactive for to long.
      void onActiveMQCommand​(Command command)
      Incoming Command object from ActiveMQ.
      void onAMQPData​(Object data)
      A new incoming data packet from the remote peer is handed off to the protocol converter for processing.
      void onAMQPException​(IOException error)
      Called when the transport detects an exception that the converter needs to respond to.
      void updateTracer()
      On changes to the transport tracing options the Protocol Converter should update its internal state so that the proper AMQP data is logged.

    • Method Detail

      • onAMQPData

        void onAMQPData​(Object data)
         throws Exception
        A new incoming data packet from the remote peer is handed off to the protocol converter for processing. The type can vary and be either an AmqpHeader at the handshake phase or a byte buffer containing the next incoming frame data from the remote.
        Parameters:
        data - the next incoming data object from the remote peer.
        Throws:
        Exception - if an error occurs processing the incoming data packet.

      • onAMQPException

        void onAMQPException​(IOException error)
        Called when the transport detects an exception that the converter needs to respond to.
        Parameters:
        error - the error that triggered this call.

      • onActiveMQCommand

        void onActiveMQCommand​(Command command)
                throws Exception
        Incoming Command object from ActiveMQ.
        Parameters:
        command - the next incoming command from the broker.
        Throws:
        Exception - if an error occurs processing the command.

      • updateTracer

        void updateTracer()
        On changes to the transport tracing options the Protocol Converter should update its internal state so that the proper AMQP data is logged.

      • keepAlive

        long keepAlive()
        throws IOException
        Perform any keep alive processing for the connection such as sending empty frames or closing connections due to remote end being inactive for to long.
        Throws:
        IOException - if an error occurs on writing heart-beats to the wire.