org.apache.camel.component.mongodb
Class MongoDbProducer
java.lang.Object
org.apache.camel.support.ServiceSupport
org.apache.camel.impl.DefaultProducer
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.
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 |
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 interface org.apache.camel.Service |
start, stop |
MongoDbProducer
public MongoDbProducer(MongoDbEndpoint endpoint)
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