org.springframework.amqp.rabbit.connection

Class SimpleConnection

java.lang.Object

org.springframework.amqp.rabbit.connection.SimpleConnection

All Implemented Interfaces:

Connection

public class SimpleConnection
extends Object
implements Connection

Simply a Connection.

Since:

1.0

Author:

Dave Syer, Gary Russell

Constructor Summary

Constructors

Constructor and Description
SimpleConnection(com.rabbitmq.client.Connection delegate, int closeTimeout)

Method Summary

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.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleConnection

public SimpleConnection(com.rabbitmq.client.Connection delegate,
                        int closeTimeout)

Method Detail

createChannel

public com.rabbitmq.client.Channel createChannel(boolean transactional)

Description copied from interface: Connection

Create a new channel, using an internally allocated channel number.

Specified by:

createChannel in interface Connection

Parameters:

transactional - true if the channel should support transactions

Returns:

a new channel descriptor, or null if none is available

close

public void close()

Description copied from interface: Connection

Close this connection and all its channels with the AMQP.REPLY_SUCCESS close code and message 'OK'. Waits for all the close operations to complete.

Specified by:

close in interface Connection

isOpen

public boolean isOpen()

Description copied from interface: Connection

Flag to indicate the status of the connection.

Specified by:

isOpen in interface Connection

Returns:

true if the connection is open

getLocalPort

public int getLocalPort()

Specified by:

getLocalPort in interface Connection

Returns:

the local port if the underlying connection supports it.

toString

public String toString()

Overrides:

toString in class Object