Package org.ikasan.component.endpoint.mongo

Class MongoComponent

java.lang.Object
org.ikasan.component.endpoint.mongo.MongoComponent
All Implemented Interfaces:
org.ikasan.spec.configuration.Configured<MongoClientConfiguration>, org.ikasan.spec.configuration.ConfiguredResource<MongoClientConfiguration>, org.ikasan.spec.management.ManagedResource
public abstract class MongoComponent extends Object implements org.ikasan.spec.management.ManagedResource, org.ikasan.spec.configuration.ConfiguredResource<MongoClientConfiguration>
Abstract Mongo component which can be managed and configured.
Author:
Ikasan Development Team

  • Field Details

    • 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 Map<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 Map<Class<?>,List<org.bson.Transformer>> bsonEncodingTransformerMap
      bson transformers that will be used when encoding from java types to bson

  • Constructor Details

    • MongoComponent

      public MongoComponent()

  • Method Details

    • setLogger

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

    • setCollections

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

    • setMongoDatabase

      public void setMongoDatabase(com.mongodb.DB mongoDatabase)

    • setBsonEncodingTransformerMap

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

    • 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 isCriticalOnStartup)
      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 configuredResourceId)
      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>

    • getMongoClientProxy

      public MongoClientProxy getMongoClientProxy()

    • setMongoClientProxy

      public void setMongoClientProxy(MongoClientProxy mongoClientProxy)

    • getMongoClient

      public com.mongodb.MongoClient getMongoClient()

    • setMongoClient

      public void setMongoClient(com.mongodb.MongoClient mongoClient)