Package org.ikasan.component.endpoint.mongo

Class MongoClientProxy

java.lang.Object

org.ikasan.component.endpoint.mongo.MongoClientProxy

All Implemented Interfaces:

org.ikasan.spec.configuration.Configured<MongoClientConfiguration>, org.ikasan.spec.configuration.ConfiguredResource<MongoClientConfiguration>, org.ikasan.spec.management.ManagedResource

public class MongoClientProxy
extends Object
implements org.ikasan.spec.management.ManagedResource, org.ikasan.spec.configuration.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	Description
MongoClientProxy()

Method Summary

Modifier and Type	Method	Description
MongoClientConfiguration	getConfiguration()
String	getConfiguredResourceId()
com.mongodb.MongoClient	getMongoClient()
boolean	isCriticalOnStartup()
boolean	isStarted()
void	setConfiguration(MongoClientConfiguration configuration)
void	setConfiguredResourceId(String id)
void	setCriticalOnStartup(boolean criticalOnStartup)
void	setManagedResourceRecoveryManager(org.ikasan.spec.management.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 Details

MongoClientProxy

public MongoClientProxy()

Method Details

startManagedResource

public void startManagedResource()

Specified by:

startManagedResource in interface org.ikasan.spec.management.ManagedResource

stopManagedResource

public void stopManagedResource()

Specified by:

stopManagedResource in interface org.ikasan.spec.management.ManagedResource

setManagedResourceRecoveryManager

public void setManagedResourceRecoveryManager(org.ikasan.spec.management.ManagedResourceRecoveryManager managedResourceRecoveryManager)

Specified by:

setManagedResourceRecoveryManager in interface org.ikasan.spec.management.ManagedResource

isCriticalOnStartup

public boolean isCriticalOnStartup()

Specified by:

isCriticalOnStartup in interface org.ikasan.spec.management.ManagedResource

setCriticalOnStartup

public void setCriticalOnStartup(boolean criticalOnStartup)

Specified by:

setCriticalOnStartup in interface org.ikasan.spec.management.ManagedResource

getConfiguredResourceId

public String getConfiguredResourceId()

Specified by:

getConfiguredResourceId in interface org.ikasan.spec.configuration.ConfiguredResource<MongoClientConfiguration>

setConfiguredResourceId

public void setConfiguredResourceId(String id)

Specified by:

setConfiguredResourceId in interface org.ikasan.spec.configuration.ConfiguredResource<MongoClientConfiguration>

getConfiguration

public MongoClientConfiguration getConfiguration()

Specified by:

getConfiguration in interface org.ikasan.spec.configuration.Configured<MongoClientConfiguration>

setConfiguration

public void setConfiguration(MongoClientConfiguration configuration)

Specified by:

setConfiguration in interface org.ikasan.spec.configuration.Configured<MongoClientConfiguration>

getMongoClient

public com.mongodb.MongoClient getMongoClient()

isStarted

public boolean isStarted()