Package org.acemq.rabbitmq.admin

Class StreamPublisherInfo

java.lang.Object

org.acemq.rabbitmq.admin.StreamPublisherInfo

public final class StreamPublisherInfo
extends Object

One publisher on a stream protocol connection.

errored() is the number to watch. A stream publisher is confirmed asynchronously, so a message the broker refused does not fail the send — it fails a callback, which an application can easily never look at.

Constructor Summary

Constructors

Constructor	Description
StreamPublisherInfo(String reference, Integer publisherId, Map<String,Object> queue, Object connection, Long published, Long confirmed, Long errored)

Method Summary

Modifier and Type	Method	Description
long	confirmed()
String	connectionName()
long	errored()
long	published()
int	publisherId()
String	reference()
String	stream()
String	toString()
String	vhost()

Methods inherited from class java.lang.Object

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

Constructor Details

StreamPublisherInfo

public StreamPublisherInfo(String reference,
 Integer publisherId,
 Map<String,Object> queue,
 Object connection,
 Long published,
 Long confirmed,
 Long errored)

Method Details

reference

public String reference()

Returns:

the publisher's name, which is what the broker deduplicates on; null for a publisher that gave none, and therefore has no deduplication

publisherId

public int publisherId()

Returns:

the id, unique only within its connection

stream

public String stream()

vhost

public String vhost()

connectionName

public String connectionName()

Returns:

the connection it is on, joining it to StreamConnectionInfo.name(); null until the broker's first statistics interval after the publisher appeared

published

public long published()

confirmed

public long confirmed()

errored

public long errored()

Returns:

messages the broker refused, which the sending code may never have noticed

toString

public String toString()

Overrides:

toString in class Object