reactor.rabbitmq

Class IdempotentClosedConnection

java.lang.Object

reactor.rabbitmq.IdempotentClosedConnection

All Implemented Interfaces:

Connection, ShutdownNotifier, Closeable, AutoCloseable

public class IdempotentClosedConnection
extends Object
implements Connection

Implement Connection that ensure closing is idempotent. It is used internally to share the same AMQP connection between Sender and Receiver instances, e.g. to use exclusive resources.

Constructor Summary

Constructors

Constructor and Description
IdempotentClosedConnection(Connection delegate)

Method Summary

Modifier and Type	Method and Description
void	abort()
void	abort(int timeout)
void	abort(int closeCode, String closeMessage)
void	abort(int closeCode, String closeMessage, int timeout)
BlockedListener	addBlockedListener(BlockedCallback blockedCallback, UnblockedCallback unblockedCallback)
void	addBlockedListener(BlockedListener listener)
void	addShutdownListener(ShutdownListener listener)
void	clearBlockedListeners()
void	close()
void	close(int timeout)
void	close(int closeCode, String closeMessage)
void	close(int closeCode, String closeMessage, int timeout)
Channel	createChannel()
Channel	createChannel(int channelNumber)
InetAddress	getAddress()
int	getChannelMax()
Map<String,Object>	getClientProperties()
String	getClientProvidedName()
ShutdownSignalException	getCloseReason()
Connection	getDelegate()
ExceptionHandler	getExceptionHandler()
int	getFrameMax()
int	getHeartbeat()
String	getId()
int	getPort()
Map<String,Object>	getServerProperties()
boolean	isOpen()
void	notifyListeners()
boolean	removeBlockedListener(BlockedListener listener)
void	removeShutdownListener(ShutdownListener listener)
void	setId(String id)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.rabbitmq.client.Connection

openChannel, openChannel

Constructor Detail

IdempotentClosedConnection

public IdempotentClosedConnection(Connection delegate)

Method Detail

getDelegate

public Connection getDelegate()

getAddress

public InetAddress getAddress()

Specified by:

getAddress in interface Connection

getPort

public int getPort()

Specified by:

getPort in interface Connection

getChannelMax

public int getChannelMax()

Specified by:

getChannelMax in interface Connection

getFrameMax

public int getFrameMax()

Specified by:

getFrameMax in interface Connection

getHeartbeat

public int getHeartbeat()

Specified by:

getHeartbeat in interface Connection

getClientProperties

public Map<String,Object> getClientProperties()

Specified by:

getClientProperties in interface Connection

getClientProvidedName

@Nullable
public String getClientProvidedName()

Specified by:

getClientProvidedName in interface Connection

getServerProperties

public Map<String,Object> getServerProperties()

Specified by:

getServerProperties in interface Connection

createChannel

@Nullable
public Channel createChannel()
                                throws IOException

Specified by:

createChannel in interface Connection

Throws:

IOException

createChannel

@Nullable
public Channel createChannel(int channelNumber)
                                throws IOException

Specified by:

createChannel in interface Connection

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Connection

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

close

public void close(int closeCode,
                  String closeMessage)
           throws IOException

Specified by:

close in interface Connection

Throws:

IOException

close

public void close(int timeout)
           throws IOException

Specified by:

close in interface Connection

Throws:

IOException

close

public void close(int closeCode,
                  String closeMessage,
                  int timeout)
           throws IOException

Specified by:

close in interface Connection

Throws:

IOException

abort

public void abort()

Specified by:

abort in interface Connection

abort

public void abort(int closeCode,
                  String closeMessage)

Specified by:

abort in interface Connection

abort

public void abort(int timeout)

Specified by:

abort in interface Connection

abort

public void abort(int closeCode,
                  String closeMessage,
                  int timeout)

Specified by:

abort in interface Connection

addBlockedListener

public void addBlockedListener(BlockedListener listener)

Specified by:

addBlockedListener in interface Connection

addBlockedListener

public BlockedListener addBlockedListener(BlockedCallback blockedCallback,
                                          UnblockedCallback unblockedCallback)

Specified by:

addBlockedListener in interface Connection

removeBlockedListener

public boolean removeBlockedListener(BlockedListener listener)

Specified by:

removeBlockedListener in interface Connection

clearBlockedListeners

public void clearBlockedListeners()

Specified by:

clearBlockedListeners in interface Connection

getExceptionHandler

public ExceptionHandler getExceptionHandler()

Specified by:

getExceptionHandler in interface Connection

getId

public String getId()

Specified by:

getId in interface Connection

setId

public void setId(String id)

Specified by:

setId in interface Connection

addShutdownListener

public void addShutdownListener(ShutdownListener listener)

Specified by:

addShutdownListener in interface ShutdownNotifier

removeShutdownListener

public void removeShutdownListener(ShutdownListener listener)

Specified by:

removeShutdownListener in interface ShutdownNotifier

getCloseReason

@Nullable
public ShutdownSignalException getCloseReason()

Specified by:

getCloseReason in interface ShutdownNotifier

notifyListeners

public void notifyListeners()

Specified by:

notifyListeners in interface ShutdownNotifier

isOpen

public boolean isOpen()

Specified by:

isOpen in interface ShutdownNotifier