Package interlok.rabbitmq

Class RabbitMqConnection

java.lang.Object

com.adaptris.core.AdaptrisConnectionImp

interlok.rabbitmq.RabbitMqConnection

All Implemented Interfaces:

AdaptrisComponent, AdaptrisConnection, ComponentLifecycle, ComponentLifecycleExtension, StateManagedComponent, ConnectionWrapper

@ComponentProfile(summary="Connection to RabbitMQ")
public class RabbitMqConnection
extends AdaptrisConnectionImp
implements ConnectionWrapper

Wraps a connection for RabbitMQ.

Field Summary

Fields inherited from class com.adaptris.core.AdaptrisConnectionImp

log

Constructor Summary

Constructors

Constructor	Description
RabbitMqConnection()

Method Summary

Modifier and Type	Method	Description
protected void	closeConnection()
ConnectionFactoryBuilder	connectionFactoryBuilder()
ConnectionFactoryBuilder	getFactoryBuilder()	Configures the underlying com.rabbitmq.client.ConnectionFactory which is responsible for creating Connection
protected void	initConnection()
protected void	prepareConnection()
void	setFactoryBuilder(ConnectionFactoryBuilder factoryBuilder)	Configures the underlying com.rabbitmq.client.ConnectionFactory which is responsible for creating Connection
protected void	startConnection()
protected void	stopConnection()
<T extends RabbitMqConnection> T	withErrorHandler(ExceptionHandlerImpl excHandler)
<T extends RabbitMqConnection> T	withFactoryBuilder(ConnectionFactoryBuilder builder)
com.rabbitmq.client.Connection	wrappedConnection()

Methods inherited from class com.adaptris.core.AdaptrisConnectionImp

addExceptionListener, addMessageConsumer, addMessageProducer, changeState, cloneForTesting, close, connectionErrorHandler, getConnectionErrorHandler, getUniqueId, getWorkersFirstOnShutdown, init, prepare, requestClose, requestInit, requestStart, requestStop, retrieveComponentState, retrieveConnection, retrieveExceptionListeners, retrieveMessageConsumers, retrieveMessageProducers, setConnectionErrorHandler, setUniqueId, setWorkersFirstOnShutdown, start, stop, workersFirstOnShutdown

Methods inherited from class java.lang.Object

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

Constructor Details

RabbitMqConnection

public RabbitMqConnection()

Method Details

prepareConnection

protected void prepareConnection()
                          throws CoreException

Specified by:

prepareConnection in class AdaptrisConnectionImp

Throws:

CoreException

initConnection

protected void initConnection()
                       throws CoreException

Specified by:

initConnection in class AdaptrisConnectionImp

Throws:

CoreException

startConnection

protected void startConnection()
                        throws CoreException

Specified by:

startConnection in class AdaptrisConnectionImp

Throws:

CoreException

stopConnection

protected void stopConnection()

Specified by:

stopConnection in class AdaptrisConnectionImp

closeConnection

protected void closeConnection()

Specified by:

closeConnection in class AdaptrisConnectionImp

wrappedConnection

public com.rabbitmq.client.Connection wrappedConnection()

Specified by:

wrappedConnection in interface ConnectionWrapper

Returns:

the wrapped connection.

connectionFactoryBuilder

public ConnectionFactoryBuilder connectionFactoryBuilder()

Specified by:

connectionFactoryBuilder in interface ConnectionWrapper

Returns:

the wrapped connection factory builder.

withFactoryBuilder

public <T extends RabbitMqConnection> T withFactoryBuilder(ConnectionFactoryBuilder builder)

withErrorHandler

public <T extends RabbitMqConnection> T withErrorHandler(ExceptionHandlerImpl excHandler)

getFactoryBuilder

public ConnectionFactoryBuilder getFactoryBuilder()

Configures the underlying com.rabbitmq.client.ConnectionFactory which is responsible for creating Connection

setFactoryBuilder

public void setFactoryBuilder(ConnectionFactoryBuilder factoryBuilder)

Configures the underlying com.rabbitmq.client.ConnectionFactory which is responsible for creating Connection