org.apache.camel.component.mongodb
Class MongoDbProducer

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.impl.DefaultProducer
          extended by org.apache.camel.component.mongodb.MongoDbProducer
All Implemented Interfaces:
org.apache.camel.IsSingleton, org.apache.camel.Processor, org.apache.camel.Producer, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class MongoDbProducer
extends org.apache.camel.impl.DefaultProducer

The MongoDb producer.


Field Summary
 
Fields inherited from class org.apache.camel.impl.DefaultProducer
log
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
MongoDbProducer(MongoDbEndpoint endpoint)
           
 
Method Summary
protected  void doAggregate(org.apache.camel.Exchange exchange)
          All headers except collection and database are non available for this operation.
protected  void doCount(org.apache.camel.Exchange exchange)
           
protected  void doFindAll(org.apache.camel.Exchange exchange)
           
protected  void doFindById(org.apache.camel.Exchange exchange)
           
protected  void doFindOneByQuery(org.apache.camel.Exchange exchange)
           
protected  void doGetStats(org.apache.camel.Exchange exchange, MongoDbOperation operation)
           
protected  void doInsert(org.apache.camel.Exchange exchange)
           
protected  void doRemove(org.apache.camel.Exchange exchange)
           
protected  void doSave(org.apache.camel.Exchange exchange)
           
protected  void doUpdate(org.apache.camel.Exchange exchange)
           
protected  void invokeOperation(MongoDbOperation operation, org.apache.camel.Exchange exchange)
          Entry method that selects the appropriate MongoDB operation and executes it
 void process(org.apache.camel.Exchange exchange)
           
 
Methods inherited from class org.apache.camel.impl.DefaultProducer
createExchange, createExchange, createExchange, doStart, doStop, getEndpoint, isSingleton, toString
 
Methods inherited from class org.apache.camel.support.ServiceSupport
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.camel.Service
start, stop
 

Constructor Detail

MongoDbProducer

public MongoDbProducer(MongoDbEndpoint endpoint)
Method Detail

process

public void process(org.apache.camel.Exchange exchange)
             throws Exception
Throws:
Exception

invokeOperation

protected void invokeOperation(MongoDbOperation operation,
                               org.apache.camel.Exchange exchange)
                        throws Exception
Entry method that selects the appropriate MongoDB operation and executes it

Parameters:
operation -
exchange -
Throws:
Exception

doGetStats

protected void doGetStats(org.apache.camel.Exchange exchange,
                          MongoDbOperation operation)
                   throws Exception
Throws:
Exception

doRemove

protected void doRemove(org.apache.camel.Exchange exchange)
                 throws Exception
Throws:
Exception

doUpdate

protected void doUpdate(org.apache.camel.Exchange exchange)
                 throws Exception
Throws:
Exception

doSave

protected void doSave(org.apache.camel.Exchange exchange)
               throws Exception
Throws:
Exception

doFindById

protected void doFindById(org.apache.camel.Exchange exchange)
                   throws Exception
Throws:
Exception

doInsert

protected void doInsert(org.apache.camel.Exchange exchange)
                 throws Exception
Throws:
Exception

doFindAll

protected void doFindAll(org.apache.camel.Exchange exchange)
                  throws Exception
Throws:
Exception

doFindOneByQuery

protected void doFindOneByQuery(org.apache.camel.Exchange exchange)
                         throws Exception
Throws:
Exception

doCount

protected void doCount(org.apache.camel.Exchange exchange)
                throws Exception
Throws:
Exception

doAggregate

protected void doAggregate(org.apache.camel.Exchange exchange)
                    throws Exception
All headers except collection and database are non available for this operation.

Parameters:
exchange -
Throws:
Exception


Apache Camel