public class SimpleConnection extends java.lang.Object implements Connection
| Constructor and Description |
|---|
SimpleConnection(com.rabbitmq.client.Connection delegate,
int closeTimeout) |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Close this connection and all its channels
with the
AMQP.REPLY_SUCCESS close code
and message 'OK'. |
com.rabbitmq.client.Channel |
createChannel(boolean transactional)
Create a new channel, using an internally allocated channel number.
|
int |
getLocalPort() |
boolean |
isOpen()
Flag to indicate the status of the connection.
|
java.lang.String |
toString() |
public SimpleConnection(com.rabbitmq.client.Connection delegate,
int closeTimeout)
public com.rabbitmq.client.Channel createChannel(boolean transactional)
ConnectioncreateChannel in interface Connectiontransactional - true if the channel should support transactionspublic void close()
ConnectionAMQP.REPLY_SUCCESS close code
and message 'OK'.
Waits for all the close operations to complete.close in interface Connectionpublic boolean isOpen()
ConnectionisOpen in interface Connectionpublic int getLocalPort()
getLocalPort in interface Connectionpublic java.lang.String toString()
toString in class java.lang.Object