Class AmqpReceiver

  • All Implemented Interfaces:
    AmqpLink, AmqpResource

    public class AmqpReceiver
    extends AmqpAbstractReceiver
    An AmqpReceiver wraps the AMQP Receiver end of a link from the remote peer which holds the corresponding Sender which transfers message accross the link. The AmqpReceiver handles all incoming deliveries by converting them or wrapping them into an ActiveMQ message object and forwarding that message on to the appropriate ActiveMQ Destination.
    • Constructor Detail

      • AmqpReceiver

        public AmqpReceiver​(AmqpSession session,
                            org.apache.qpid.proton.engine.Receiver endpoint,
                            ProducerInfo producerInfo)
        Create a new instance of an AmqpReceiver
        session - the Session that is the parent of this AmqpReceiver instance.
        endpoint - the AMQP receiver endpoint that the class manages.
        producerInfo - the ProducerInfo instance that contains this sender's configuration.
    • Method Detail

      • close

        public void close()
        Description copied from interface: AmqpResource
        Request from the remote peer to close this resource.
        Specified by:
        close in interface AmqpResource
        close in class AmqpAbstractLink<org.apache.qpid.proton.engine.Receiver>
      • getProducerId

        public ProducerId getProducerId()
        the ActiveMQ ProducerId used to register this Receiver on the Broker.
      • getDestination

        public ActiveMQDestination getDestination()
        the ActiveMQDestination that this link is servicing.
      • setDestination

        public void setDestination​(ActiveMQDestination destination)
        Description copied from interface: AmqpLink
        Sets the ActiveMQDestination that this link will be servicing.
        destination - the ActiveMQDestination that this link services.
      • isAnonymous

        public boolean isAnonymous()
        If the Sender that initiated this Receiver endpoint did not define an address then it is using anonymous mode and message are to be routed to the address that is defined in the AMQP message 'To' field.
        true if this Receiver should operate in anonymous mode.