Class ConsumeOkEvent

  • All Implemented Interfaces:
    Serializable

    public class ConsumeOkEvent
    extends AmqpEvent
    An AmqpEvent emitted by the listener container when consumer is subscribed to the queue.
    Since:
    1.7.5
    Author:
    Gary Russell, Artem Bilan
    See Also:
    Serialized Form
    • Constructor Detail

      • ConsumeOkEvent

        public ConsumeOkEvent​(Object source,
                              String queue,
                              String consumerTag)
        Instantiate a ConsumeOkEvent based on the provided consumer, queue and consumer tag.
        Parameters:
        source - the consumer subscribed to the queue
        queue - the queue to consume
        consumerTag - the tag indicate a consumer subscription
    • Method Detail

      • getQueue

        public String getQueue()
        Obtain the queue name a consumer has been subscribed.
        Returns:
        the queue name a consumer subscribed.
        Since:
        1.7.7
      • getConsumerTag

        public String getConsumerTag()
        Obtain the consumer tag assigned to the consumer.
        Returns:
        the consumer tag for subscription.
        Since:
        1.7.7