org.ikasan.component.endpoint.mongo

Class MongoClientProxy

java.lang.Object

org.ikasan.component.endpoint.mongo.MongoClientProxy

All Implemented Interfaces:

Configured<MongoClientConfiguration>, ConfiguredResource<MongoClientConfiguration>, ManagedResource

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

MongoClient proxy for injecting into a MongoComponent Allows for a single MongoClient to be shared among components, but have multiple MongoComponents safely manage its lifecycle

Constructor Summary

Constructors

Constructor and Description
MongoClientProxy()

Method Summary

Modifier and Type	Method and Description
MongoClientConfiguration	getConfiguration()
java.lang.String	getConfiguredResourceId()
com.mongodb.MongoClient	getMongoClient()
boolean	isCriticalOnStartup()
boolean	isStarted()
void	setConfiguration(MongoClientConfiguration configuration)
void	setConfiguredResourceId(java.lang.String id)
void	setCriticalOnStartup(boolean criticalOnStartup)
void	setManagedResourceRecoveryManager(ManagedResourceRecoveryManager managedResourceRecoveryManager)
void	startManagedResource()
void	stopManagedResource()

Methods inherited from class java.lang.Object

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

Constructor Detail

MongoClientProxy

public MongoClientProxy()

Method Detail

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 criticalOnStartup)

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 id)

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>

getMongoClient

public com.mongodb.MongoClient getMongoClient()

isStarted

public boolean isStarted()