Class AmqpAbstractReceiver

    • Field Detail

      • current

        protected org.fusesource.hawtbuf.ByteArrayOutputStream current
      • recvBuffer

        protected final byte[] recvBuffer
      • configuredCredit

        protected final int configuredCredit
    • Constructor Detail

      • AmqpAbstractReceiver

        public AmqpAbstractReceiver​(AmqpSession session,
                                    org.apache.qpid.proton.engine.Receiver endpoint)
        Handle create of new AMQP Receiver instance.
        Parameters:
        session - the AmqpSession that servers as the parent of this Link.
        endpoint - the Receiver endpoint being managed by this class.
    • Method Detail

      • detach

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

        public void flow()
                  throws Exception
        Description copied from interface: AmqpLink
        Handles an incoming flow control.
        Throws:
        Exception
      • getConfiguredReceiverCredit

        public int getConfiguredReceiverCredit()
        Returns the amount of receiver credit that has been configured for this AMQP transport. If no value was configured on the TransportConnector URI then a sensible default is used.
        Returns:
        the configured receiver credit to grant.
      • flow

        public void flow​(int credits)
        Provide the receiver endpoint with the given amount of credits.
        Parameters:
        credits - the credit value to pass on to the wrapped Receiver.
      • commit

        public void commit​(LocalTransactionId txnId)
                    throws Exception
        Description copied from interface: AmqpLink
        Handle work necessary on commit of transacted resources associated with this Link instance.
        Parameters:
        txnId - The Transaction ID being committed.
        Throws:
        Exception - if an error occurs while performing the commit.
      • rollback

        public void rollback​(LocalTransactionId txnId)
                      throws Exception
        Description copied from interface: AmqpLink
        Handle work necessary on rollback of transacted resources associated with this Link instance.
        Parameters:
        txnId - The Transaction ID being rolled back.
        Throws:
        Exception - if an error occurs while performing the rollback.
      • delivery

        public void delivery​(org.apache.qpid.proton.engine.Delivery delivery)
                      throws Exception
        Description copied from interface: AmqpLink
        Called when a new Delivery arrives for the given Link.
        Parameters:
        delivery - the newly arrived delivery on this link.
        Throws:
        Exception - if an error occurs while processing the new Delivery.
      • processDelivery

        protected abstract void processDelivery​(org.apache.qpid.proton.engine.Delivery delivery,
                                                org.fusesource.hawtbuf.Buffer deliveryBytes)
                                         throws Exception
        Throws:
        Exception