Package org.acemq.rabbitmq.admin

Class ConsumerInfo

java.lang.Object

org.acemq.rabbitmq.admin.ConsumerInfo

public final class ConsumerInfo
extends Object

One consumer on one queue.

The list that answers "is anything actually reading this queue, and is it allowed to?" — which a consumer count alone does not, because a single-active-consumer queue reports several consumers of which exactly one is active() and the rest are waiting.

Constructor Summary

Constructors

Constructor	Description
ConsumerInfo(String consumerTag, Map<String,Object> queueDetails, Boolean ackRequired, Boolean exclusive, Boolean active, String activityStatus, Integer prefetchCount, Map<String,Object> channelDetails, Map<String,Object> arguments)

Method Summary

Modifier and Type	Method	Description
boolean	ackRequired()
boolean	active()
String	activityStatus()
Map<String,Object>	arguments()
String	channelName()
String	consumerTag()
boolean	exclusive()
int	prefetchCount()
String	queue()
String	toString()
String	vhost()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

ConsumerInfo

public ConsumerInfo(String consumerTag,
 Map<String,Object> queueDetails,
 Boolean ackRequired,
 Boolean exclusive,
 Boolean active,
 String activityStatus,
 Integer prefetchCount,
 Map<String,Object> channelDetails,
 Map<String,Object> arguments)

Method Details

consumerTag

public String consumerTag()

Returns:

the tag the client chose, which is what it uses to cancel

queue

public String queue()

vhost

public String vhost()

ackRequired

public boolean ackRequired()

Returns:

whether the consumer must acknowledge. False means auto-ack, and an auto-ack consumer loses every unprocessed message if it dies

exclusive

public boolean exclusive()

active

public boolean active()

Returns:

whether this consumer is currently receiving. On a queue with single active consumer, or a paused quorum queue, a consumer can be attached and not active — which a consumer count cannot distinguish from one that is working

activityStatus

public String activityStatus()

Returns:

up, waiting or suspected_down

prefetchCount

public int prefetchCount()

channelName

public String channelName()

Returns:

the channel this consumer is on, joining it to ChannelInfo.name()

arguments

public Map<String,Object> arguments()

toString

public String toString()

Overrides:

toString in class Object