org.springframework.amqp.rabbit.connection
Class SimpleConnection

java.lang.Object
  org.springframework.amqp.rabbit.connection.SimpleConnection

All Implemented Interfaces:

Connection

public class SimpleConnection
extends java.lang.Object
implements Connection

Constructor Summary

SimpleConnection(com.rabbitmq.client.Connection delegate)

Method Summary

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.
boolean	isOpen() Flag to indicate the status of the connection.

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleConnection

public SimpleConnection(com.rabbitmq.client.Connection delegate)

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