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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

MongoDBConnection

public MongoDBConnection()

MongoDBConnection

public MongoDBConnection(java.lang.String connectionUri,
                         java.lang.String database)

Method Detail

prepareConnection

protected void prepareConnection()

Specified by:

prepareConnection in class AdaptrisConnectionImp

initConnection

protected void initConnection()
                       throws CoreException

Specified by:

initConnection in class AdaptrisConnectionImp

Throws:

CoreException

startConnection

protected void startConnection()

Specified by:

startConnection in class AdaptrisConnectionImp

stopConnection

protected void stopConnection()

Specified by:

stopConnection in class AdaptrisConnectionImp

closeConnection

protected void closeConnection()

Specified by:

closeConnection in class AdaptrisConnectionImp

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)