public class ConsumeOkEvent extends AmqpEvent
AmqpEvent emitted by the listener container
when consumer is subscribed to the queue.source| Constructor and Description |
|---|
ConsumeOkEvent(Object source,
String queue,
String consumerTag)
Instantiate a
ConsumeOkEvent based on the provided
consumer, queue and consumer tag. |
| Modifier and Type | Method and Description |
|---|---|
String |
getConsumerTag()
Obtain the consumer tag assigned to the consumer.
|
String |
getQueue()
Obtain the queue name a consumer has been subscribed.
|
String |
toString() |
getTimestampgetSourcepublic ConsumeOkEvent(Object source, String queue, String consumerTag)
ConsumeOkEvent based on the provided
consumer, queue and consumer tag.source - the consumer subscribed to the queuequeue - the queue to consumeconsumerTag - the tag indicate a consumer subscriptionpublic String getQueue()
public String getConsumerTag()
public String toString()
toString in class EventObject