Package com.adaptris.core.mongodb
Class MongoDBProducer
- java.lang.Object
-
- com.adaptris.core.AdaptrisMessageWorkerImp
-
- com.adaptris.core.AdaptrisMessageProducerImp
-
- com.adaptris.core.RequestReplyProducerBase
-
- com.adaptris.core.RequestReplyProducerImp
-
- com.adaptris.core.mongodb.MongoDBProducer
-
- All Implemented Interfaces:
AdaptrisComponent
,AdaptrisMessageProducer
,AdaptrisMessageSender
,AdaptrisMessageWorker
,ComponentLifecycle
,ComponentLifecycleExtension
,MessageEventGenerator
- Direct Known Subclasses:
MongoDBArrayProducer
,MongoDBRetrieveProducer
,MongoDBUpdateDataTypesProducer
public abstract class MongoDBProducer extends RequestReplyProducerImp
-
-
Field Summary
-
Fields inherited from class com.adaptris.core.AdaptrisMessageWorkerImp
log
-
-
Constructor Summary
Constructors Constructor Description MongoDBProducer()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected long
defaultTimeout()
protected void
doProduce(AdaptrisMessage msg, java.lang.String endpoint)
protected AdaptrisMessage
doRequest(AdaptrisMessage msg, java.lang.String endpoint, long timeout)
protected abstract AdaptrisMessage
doRequest(AdaptrisMessage msg, java.lang.String collection, long timeout, AdaptrisMessage reply)
java.lang.String
endpoint(AdaptrisMessage msg)
java.lang.String
getCollection()
The MongoDB collection name.protected com.mongodb.MongoClient
getMongoClient()
protected com.mongodb.client.MongoDatabase
getMongoDatabase()
void
init()
void
prepare()
void
setCollection(java.lang.String collection)
The MongoDB collection name.<T extends MongoDBProducer>
TwithCollection(java.lang.String s)
-
Methods inherited from class com.adaptris.core.RequestReplyProducerImp
produce, request, request
-
Methods inherited from class com.adaptris.core.RequestReplyProducerBase
copyReplyContents, getIgnoreReplyMetadata, mergeReply, setIgnoreReplyMetadata
-
Methods inherited from class com.adaptris.core.AdaptrisMessageProducerImp
createName
-
Methods inherited from class com.adaptris.core.AdaptrisMessageWorkerImp
createQualifier, decode, encode, getEncoder, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isTrackingEndpoint, registerConnection, registerEncoderMessageFactory, retrieveConnection, setEncoder, setIsTrackingEndpoint, setMessageFactory, setUniqueId, withMessageFactory, withUniqueID
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface com.adaptris.core.AdaptrisComponent
getUniqueId
-
Methods inherited from interface com.adaptris.core.AdaptrisMessageWorker
decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory
-
Methods inherited from interface com.adaptris.core.ComponentLifecycle
close, start, stop
-
Methods inherited from interface com.adaptris.core.MessageEventGenerator
createQualifier, isTrackingEndpoint
-
-
-
-
Method Detail
-
prepare
public void prepare()
-
init
public void init() throws CoreException
- Throws:
CoreException
-
doRequest
protected AdaptrisMessage doRequest(AdaptrisMessage msg, java.lang.String endpoint, long timeout) throws ProduceException
- Specified by:
doRequest
in classRequestReplyProducerImp
- Throws:
ProduceException
-
doProduce
protected void doProduce(AdaptrisMessage msg, java.lang.String endpoint) throws ProduceException
- Specified by:
doProduce
in classRequestReplyProducerImp
- Throws:
ProduceException
-
doRequest
protected abstract AdaptrisMessage doRequest(AdaptrisMessage msg, java.lang.String collection, long timeout, AdaptrisMessage reply) throws ProduceException
- Throws:
ProduceException
-
defaultTimeout
protected long defaultTimeout()
- Specified by:
defaultTimeout
in classRequestReplyProducerBase
-
getMongoClient
protected com.mongodb.MongoClient getMongoClient()
-
getMongoDatabase
protected com.mongodb.client.MongoDatabase getMongoDatabase()
-
endpoint
public java.lang.String endpoint(AdaptrisMessage msg) throws ProduceException
- Specified by:
endpoint
in classAdaptrisMessageProducerImp
- Throws:
ProduceException
-
withCollection
public <T extends MongoDBProducer> T withCollection(java.lang.String s)
-
getCollection
public java.lang.String getCollection()
The MongoDB collection name.
-
setCollection
public void setCollection(java.lang.String collection)
The MongoDB collection name.
-
-