Package org.acemq.rabbitmq.admin

Class ChannelInfo

java.lang.Object

org.acemq.rabbitmq.admin.ChannelInfo

public final class ChannelInfo
extends Object

One channel on one connection.

Where prefetch and unacknowledged counts live, which makes this the view that explains a consumer that has stopped moving: messagesUnacknowledged() equal to prefetchCount() is a consumer holding its whole allowance and acknowledging nothing. The broker will send it no more until it does, and from the queue's side that is indistinguishable from a consumer that is merely slow.

Constructor Summary

Constructors

Constructor	Description
ChannelInfo(String name, String user, String vhost, String node, Integer number, String state, Integer prefetchCount, Integer consumerCount, Integer messagesUnacknowledged, Integer messagesUnconfirmed, Boolean confirm, Boolean transactional, Map<String,Object> connectionDetails)

Method Summary

Modifier and Type	Method	Description
boolean	confirm()
String	connectionName()
int	consumerCount()
boolean	isAtPrefetchLimit()
int	messagesUnacknowledged()
int	messagesUnconfirmed()
String	name()
String	node()
int	number()
int	prefetchCount()
String	state()
String	toString()
boolean	transactional()
String	user()
String	vhost()

Methods inherited from class java.lang.Object

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

Constructor Details

ChannelInfo

public ChannelInfo(String name,
 String user,
 String vhost,
 String node,
 Integer number,
 String state,
 Integer prefetchCount,
 Integer consumerCount,
 Integer messagesUnacknowledged,
 Integer messagesUnconfirmed,
 Boolean confirm,
 Boolean transactional,
 Map<String,Object> connectionDetails)

Method Details

name

public String name()

user

public String user()

vhost

public String vhost()

node

public String node()

number

public int number()

Returns:

the channel number within its connection

state

public String state()

Returns:

running or flow. flow is the broker throttling this channel

prefetchCount

public int prefetchCount()

Returns:

how many unacknowledged deliveries this channel will accept. Zero means unlimited

consumerCount

public int consumerCount()

messagesUnacknowledged

public int messagesUnacknowledged()

Returns:

deliveries sent and not yet acknowledged

messagesUnconfirmed

public int messagesUnconfirmed()

Returns:

publishes sent and not yet confirmed by the broker

confirm

public boolean confirm()

Returns:

whether publisher confirms are on

transactional

public boolean transactional()

connectionName

public String connectionName()

Returns:

the name of the connection this channel belongs to

isAtPrefetchLimit

public boolean isAtPrefetchLimit()

Returns:

whether this channel is holding its entire prefetch allowance unacknowledged. The broker will send it nothing further until something is acked, so a consumer in this state has stopped and looks, from the queue, exactly like one that is slow

toString

public String toString()

Overrides:

toString in class Object