org.springframework.amqp.rabbit.connection

Class CachingConnectionFactory.ChannelCachingConnectionProxy

java.lang.Object

org.springframework.amqp.rabbit.connection.CachingConnectionFactory.ChannelCachingConnectionProxy

All Implemented Interfaces:

Connection, ConnectionProxy

Enclosing class:

CachingConnectionFactory

private class CachingConnectionFactory.ChannelCachingConnectionProxy
extends java.lang.Object
implements Connection, ConnectionProxy

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.atomic.AtomicBoolean	closeNotified
private Connection	target

Constructor Summary

Constructors

Constructor and Description
ChannelCachingConnectionProxy(Connection target)

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'.
private com.rabbitmq.client.Channel	createBareChannel(boolean transactional)
com.rabbitmq.client.Channel	createChannel(boolean transactional) Create a new channel, using an internally allocated channel number.
void	destroy()
boolean	equals(java.lang.Object obj)
Connection	getTargetConnection() Return the target Channel of this proxy.
int	hashCode()
boolean	isOpen() Flag to indicate the status of the connection.
private void	notifyCloseIfNecessary()
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

target

private volatile Connection target

closeNotified

private final java.util.concurrent.atomic.AtomicBoolean closeNotified

Constructor Detail

ChannelCachingConnectionProxy

public ChannelCachingConnectionProxy(Connection target)

Method Detail

createBareChannel

private com.rabbitmq.client.Channel createBareChannel(boolean transactional)

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

destroy

public void destroy()

notifyCloseIfNecessary

private void notifyCloseIfNecessary()

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

getTargetConnection

public Connection getTargetConnection()

Description copied from interface: ConnectionProxy

Return the target Channel of this proxy.

This will typically be the native provider Connection

Specified by:

getTargetConnection in interface ConnectionProxy

Returns:

the underlying Connection (never null)

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object