Package org.acemq.rabbitmq.admin

Class StreamConsumerInfo

java.lang.Object

org.acemq.rabbitmq.admin.StreamConsumerInfo

public final class StreamConsumerInfo
extends Object

One subscription on a stream protocol connection.

A stream is not drained, so there is no queue depth to read. offsetLag() is the equivalent: how far behind the end of the stream this consumer is.

Constructor Summary

Constructors

Constructor	Description
StreamConsumerInfo(Integer subscriptionId, Object properties, Map<String,Object> queue, Object connection, Boolean active, Long offset, Long offsetLag, Long consumed, Long credits)

Method Summary

Modifier and Type	Method	Description
boolean	active()
String	connectionName()
long	consumed()
long	credits()
String	name()
long	offset()
long	offsetLag()
String	stream()
int	subscriptionId()
String	toString()
String	vhost()

Methods inherited from class java.lang.Object

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

Constructor Details

StreamConsumerInfo

public StreamConsumerInfo(Integer subscriptionId,
 Object properties,
 Map<String,Object> queue,
 Object connection,
 Boolean active,
 Long offset,
 Long offsetLag,
 Long consumed,
 Long credits)

Method Details

subscriptionId

public int subscriptionId()

Returns:

the id, unique only within its connection

name

public String name()

Returns:

the consumer's name, under which the broker stores its offset; null for a consumer that tracks no offset and so starts over wherever it is told to on every restart

stream

public String stream()

vhost

public String vhost()

connectionName

public String connectionName()

Returns:

the connection it is on; null until the broker's first statistics interval

active

public boolean active()

Returns:

whether it is receiving. With single active consumer, the others in the group are attached and waiting

offset

public long offset()

offsetLag

public long offsetLag()

Returns:

how many messages it is behind the end of the stream

consumed

public long consumed()

credits

public long credits()

Returns:

chunks the client is ready for. A zero that stays zero is a client that stopped asking

toString

public String toString()

Overrides:

toString in class Object