Package org.acemq.rabbitmq.admin

Class StreamConnectionInfo

java.lang.Object

org.acemq.rabbitmq.admin.StreamConnectionInfo

public final class StreamConnectionInfo
extends Object

One connection over RabbitMQ's stream protocol, on port 5552.

RabbitAdmin.connections() lists these too, among every other protocol's, with the AMQP-shaped fields that mean little for a stream client. This list holds only stream connections, and its name() is what StreamPublisherInfo.connectionName() and StreamConsumerInfo.connectionName() refer to.

Constructor Summary

Constructors

Constructor	Description
StreamConnectionInfo(String name, String vhost, String user, String node, String state, String peerHost, Integer peerPort, String clientProvidedName, Long connectedAt)

Method Summary

Modifier and Type	Method	Description
String	clientProvidedName()
long	connectedAt()
String	name()
String	node()
String	peerHost()
int	peerPort()
String	state()
String	toString()
String	user()
String	vhost()

Methods inherited from class java.lang.Object

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

Constructor Details

StreamConnectionInfo

public StreamConnectionInfo(String name,
 String vhost,
 String user,
 String node,
 String state,
 String peerHost,
 Integer peerPort,
 String clientProvidedName,
 Long connectedAt)

Method Details

name

public String name()

Returns:

the broker's name for it, joining it to the connection names publishers carry

vhost

public String vhost()

user

public String user()

node

public String node()

state

public String state()

Returns:

running, usually

peerHost

public String peerHost()

peerPort

public int peerPort()

clientProvidedName

public String clientProvidedName()

Returns:

the name the client gave itself, or null when it gave none

connectedAt

public long connectedAt()

Returns:

when it connected, in milliseconds since the epoch; 0 when not reported

toString

public String toString()

Overrides:

toString in class Object