Interface Consumer

    • Method Detail

      • handleCancelOk

        void handleCancelOk​(String consumerTag)
        Called when the consumer is cancelled by a call to Channel.basicCancel(java.lang.String).
        Parameters:
        consumerTag - the consumer tag associated with the consumer
      • handleShutdownSignal

        void handleShutdownSignal​(String consumerTag,
                                  ShutdownSignalException sig)
        Called when either the channel or the underlying connection has been shut down.
        Parameters:
        consumerTag - the consumer tag associated with the consumer
        sig - a ShutdownSignalException indicating the reason for the shut down
      • handleRecoverOk

        void handleRecoverOk​(String consumerTag)
        Called when a basic.recover-ok is received in reply to a basic.recover. All messages received before this is invoked that haven't been ack'ed will be re-delivered. All messages received afterwards won't be.
        Parameters:
        consumerTag - the consumer tag associated with the consumer
      • handleDelivery

        void handleDelivery​(String consumerTag,
                            Envelope envelope,
                            AMQP.BasicProperties properties,
                            byte[] body)
                     throws IOException
        Called when a basic.deliver is received for this consumer.
        Parameters:
        consumerTag - the consumer tag associated with the consumer
        envelope - packaging data for the message
        properties - content header data for the message
        body - the message body (opaque, client-specific byte array)
        Throws:
        IOException - if the consumer encounters an I/O error while processing the message
        See Also:
        Envelope