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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidcloseConnection()ConnectionFactoryBuilderconnectionFactoryBuilder()ConnectionFactoryBuildergetFactoryBuilder()Configures the underlyingcom.rabbitmq.client.ConnectionFactorywhich is responsible for creatingConnectionprotected voidinitConnection()protected voidprepareConnection()voidsetFactoryBuilder(ConnectionFactoryBuilder factoryBuilder)Configures the underlyingcom.rabbitmq.client.ConnectionFactorywhich is responsible for creatingConnectionprotected voidstartConnection()protected voidstopConnection()<T extends RabbitMqConnection>
TwithErrorHandler(ExceptionHandlerImpl excHandler)<T extends RabbitMqConnection>
TwithFactoryBuilder(ConnectionFactoryBuilder builder)com.rabbitmq.client.ConnectionwrappedConnection()-
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
-
-
-
-
Method Detail
-
prepareConnection
protected void prepareConnection() throws CoreException- Specified by:
prepareConnectionin classAdaptrisConnectionImp- Throws:
CoreException
-
initConnection
protected void initConnection() throws CoreException- Specified by:
initConnectionin classAdaptrisConnectionImp- Throws:
CoreException
-
startConnection
protected void startConnection() throws CoreException- Specified by:
startConnectionin classAdaptrisConnectionImp- Throws:
CoreException
-
stopConnection
protected void stopConnection()
- Specified by:
stopConnectionin classAdaptrisConnectionImp
-
closeConnection
protected void closeConnection()
- Specified by:
closeConnectionin classAdaptrisConnectionImp
-
wrappedConnection
public com.rabbitmq.client.Connection wrappedConnection()
- Specified by:
wrappedConnectionin interfaceConnectionWrapper- Returns:
- the wrapped connection.
-
connectionFactoryBuilder
public ConnectionFactoryBuilder connectionFactoryBuilder()
- Specified by:
connectionFactoryBuilderin interfaceConnectionWrapper- 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 underlyingcom.rabbitmq.client.ConnectionFactorywhich is responsible for creatingConnection
-
setFactoryBuilder
public void setFactoryBuilder(ConnectionFactoryBuilder factoryBuilder)
Configures the underlyingcom.rabbitmq.client.ConnectionFactorywhich is responsible for creatingConnection
-
-