Spring AMQP

org.springframework.amqp.rabbit.connection
Class SimpleConnection

java.lang.Object
  extended by org.springframework.amqp.rabbit.connection.SimpleConnection
All Implemented Interfaces:
Connection

public class SimpleConnection
extends 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

Spring AMQP

Copyright © 2011. All Rights Reserved.