org.ikasan.component.endpoint.mongo

Class MongoComponent

java.lang.Object

org.ikasan.component.endpoint.mongo.MongoComponent

All Implemented Interfaces:

Configured<MongoClientConfiguration>, ConfiguredResource<MongoClientConfiguration>, ManagedResource

public abstract class MongoComponent
extends java.lang.Object
implements ManagedResource, ConfiguredResource<MongoClientConfiguration>

Abstract Mongo component which can be managed and configured.

Author:

Ikasan Development Team

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.Map<java.lang.Class<?>,java.util.List<org.bson.Transformer>>	bsonEncodingTransformerMap bson transformers that will be used when encoding from java types to bson
protected java.util.Map<java.lang.String,com.mongodb.DBCollection>	collections handle to all referenced collections
protected MongoClientConfiguration	configuration configuration
protected com.mongodb.MongoClient	mongoClient instantiated mongoclient
protected MongoClientProxy	mongoClientProxy optional proxy for sharing a Mongo client
protected boolean	mongoClientSet set if the setter on MongoClient is used (so we don't close it)
protected com.mongodb.DB	mongoDatabase handle to mongoDB instance

Constructor Summary

Constructors

Constructor and Description
MongoComponent()

Method Summary

Modifier and Type	Method and Description
MongoClientConfiguration	getConfiguration()
java.lang.String	getConfiguredResourceId()
com.mongodb.MongoClient	getMongoClient()
MongoClientProxy	getMongoClientProxy()
boolean	isCriticalOnStartup()
void	setBsonEncodingTransformerMap(java.util.Map<java.lang.Class<?>,java.util.List<org.bson.Transformer>> bsonEncodingTransformerMap)
void	setCollections(java.util.Map<java.lang.String,com.mongodb.DBCollection> collections)
void	setConfiguration(MongoClientConfiguration configuration)
void	setConfiguredResourceId(java.lang.String configuredResourceId)
void	setCriticalOnStartup(boolean isCriticalOnStartup)
static void	setLogger(org.slf4j.Logger logger)
void	setManagedResourceRecoveryManager(ManagedResourceRecoveryManager managedResourceRecoveryManager)
void	setMongoClient(com.mongodb.MongoClient mongoClient)
void	setMongoClientProxy(MongoClientProxy mongoClientProxy)
void	setMongoDatabase(com.mongodb.DB mongoDatabase)
void	startManagedResource()
void	stopManagedResource()

Methods inherited from class java.lang.Object

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

Field Detail

configuration

protected MongoClientConfiguration configuration

configuration

mongoClient

protected com.mongodb.MongoClient mongoClient

instantiated mongoclient

mongoClientProxy

protected MongoClientProxy mongoClientProxy

optional proxy for sharing a Mongo client

collections

protected java.util.Map<java.lang.String,com.mongodb.DBCollection> collections

handle to all referenced collections

mongoDatabase

protected com.mongodb.DB mongoDatabase

handle to mongoDB instance

mongoClientSet

protected boolean mongoClientSet

set if the setter on MongoClient is used (so we don't close it)

bsonEncodingTransformerMap

protected java.util.Map<java.lang.Class<?>,java.util.List<org.bson.Transformer>> bsonEncodingTransformerMap

bson transformers that will be used when encoding from java types to bson

Constructor Detail

MongoComponent

public MongoComponent()

Method Detail

setLogger

public static void setLogger(org.slf4j.Logger logger)

setCollections

public void setCollections(java.util.Map<java.lang.String,com.mongodb.DBCollection> collections)

setMongoDatabase

public void setMongoDatabase(com.mongodb.DB mongoDatabase)

setBsonEncodingTransformerMap

public void setBsonEncodingTransformerMap(java.util.Map<java.lang.Class<?>,java.util.List<org.bson.Transformer>> bsonEncodingTransformerMap)

startManagedResource

public void startManagedResource()

Specified by:

startManagedResource in interface ManagedResource

stopManagedResource

public void stopManagedResource()

Specified by:

stopManagedResource in interface ManagedResource

setManagedResourceRecoveryManager

public void setManagedResourceRecoveryManager(ManagedResourceRecoveryManager managedResourceRecoveryManager)

Specified by:

setManagedResourceRecoveryManager in interface ManagedResource

isCriticalOnStartup

public boolean isCriticalOnStartup()

Specified by:

isCriticalOnStartup in interface ManagedResource

setCriticalOnStartup

public void setCriticalOnStartup(boolean isCriticalOnStartup)

Specified by:

setCriticalOnStartup in interface ManagedResource

getConfiguredResourceId

public java.lang.String getConfiguredResourceId()

Specified by:

getConfiguredResourceId in interface ConfiguredResource<MongoClientConfiguration>

setConfiguredResourceId

public void setConfiguredResourceId(java.lang.String configuredResourceId)

Specified by:

setConfiguredResourceId in interface ConfiguredResource<MongoClientConfiguration>

getConfiguration

public MongoClientConfiguration getConfiguration()

Specified by:

getConfiguration in interface Configured<MongoClientConfiguration>

setConfiguration

public void setConfiguration(MongoClientConfiguration configuration)

Specified by:

setConfiguration in interface Configured<MongoClientConfiguration>

getMongoClientProxy

public MongoClientProxy getMongoClientProxy()

setMongoClientProxy

public void setMongoClientProxy(MongoClientProxy mongoClientProxy)

getMongoClient

public com.mongodb.MongoClient getMongoClient()

setMongoClient

public void setMongoClient(com.mongodb.MongoClient mongoClient)