Package com.adaptris.core.mongodb
Class MongoDBConnection
- java.lang.Object
-
- com.adaptris.core.AdaptrisConnectionImp
-
- com.adaptris.core.AllowsRetriesConnection
-
- com.adaptris.core.mongodb.MongoDBConnection
-
- All Implemented Interfaces:
AdaptrisComponent
,AdaptrisConnection
,ComponentLifecycle
,ComponentLifecycleExtension
,StateManagedComponent
@ComponentProfile(summary="Connect to MongoDB,", tag="connections,mongodb") public class MongoDBConnection extends AllowsRetriesConnection
In the adapter configuration file this class is aliased as mongodb-connection which is the preferred alternative to the fully qualified classname when building your configuration.
-
-
Field Summary
-
Fields inherited from class com.adaptris.core.AdaptrisConnectionImp
log
-
-
Constructor Summary
Constructors Constructor Description MongoDBConnection()
MongoDBConnection(java.lang.String connectionUri, java.lang.String database)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
closeConnection()
java.lang.String
getConnectionUri()
java.lang.String
getDatabase()
protected void
initConnection()
protected void
prepareConnection()
protected com.mongodb.MongoClient
retrieveMongoClient()
protected com.mongodb.client.MongoDatabase
retrieveMongoDatabase()
void
setConnectionUri(java.lang.String connectionUri)
void
setDatabase(java.lang.String database)
protected void
startConnection()
protected void
stopConnection()
-
Methods inherited from class com.adaptris.core.AllowsRetriesConnection
connectionAttempts, connectionRetryInterval, createLoggingStatement, getConnectionAttempts, getConnectionRetryInterval, logWarning, setConnectionAttempts, setConnectionRetryInterval
-
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()
- Specified by:
prepareConnection
in classAdaptrisConnectionImp
-
initConnection
protected void initConnection() throws CoreException
- Specified by:
initConnection
in classAdaptrisConnectionImp
- Throws:
CoreException
-
startConnection
protected void startConnection()
- Specified by:
startConnection
in classAdaptrisConnectionImp
-
stopConnection
protected void stopConnection()
- Specified by:
stopConnection
in classAdaptrisConnectionImp
-
closeConnection
protected void closeConnection()
- Specified by:
closeConnection
in classAdaptrisConnectionImp
-
retrieveMongoClient
protected com.mongodb.MongoClient retrieveMongoClient()
-
retrieveMongoDatabase
protected com.mongodb.client.MongoDatabase retrieveMongoDatabase()
-
getConnectionUri
public java.lang.String getConnectionUri()
-
setConnectionUri
public void setConnectionUri(java.lang.String connectionUri)
-
getDatabase
public java.lang.String getDatabase()
-
setDatabase
public void setDatabase(java.lang.String database)
-
-