Package com.adaptris.core.mongodb
Class MongoDBRetrieveProducer
- java.lang.Object
-
- com.adaptris.core.AdaptrisMessageWorkerImp
-
- com.adaptris.core.AdaptrisMessageProducerImp
-
- com.adaptris.core.RequestReplyProducerBase
-
- com.adaptris.core.RequestReplyProducerImp
-
- com.adaptris.core.mongodb.MongoDBProducer
-
- com.adaptris.core.mongodb.MongoDBRetrieveProducer
-
- All Implemented Interfaces:
AdaptrisComponent
,AdaptrisMessageProducer
,AdaptrisMessageSender
,AdaptrisMessageWorker
,ComponentLifecycle
,ComponentLifecycleExtension
,MessageEventGenerator
- Direct Known Subclasses:
MongoDBAggregateProducer
,MongoDBFindProducer
public abstract class MongoDBRetrieveProducer extends MongoDBProducer
-
-
Field Summary
-
Fields inherited from class com.adaptris.core.AdaptrisMessageWorkerImp
log
-
-
Constructor Summary
Constructors Constructor Description MongoDBRetrieveProducer()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected AdaptrisMessage
doRequest(AdaptrisMessage msg, java.lang.String collectionName, long timeout, AdaptrisMessage reply)
java.lang.Integer
getBatchSize()
JsonOutputSettings
getJsonOutputSettings()
protected abstract com.mongodb.client.MongoIterable<org.bson.Document>
retrieveResults(com.mongodb.client.MongoCollection<org.bson.Document> collection, AdaptrisMessage msg)
void
setBatchSize(java.lang.Integer batchSize)
void
setJsonOutputSettings(JsonOutputSettings jsonOutputSettings)
-
Methods inherited from class com.adaptris.core.mongodb.MongoDBProducer
defaultTimeout, doProduce, doRequest, endpoint, getCollection, getMongoClient, getMongoDatabase, init, prepare, setCollection, withCollection
-
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
-
doRequest
protected final AdaptrisMessage doRequest(AdaptrisMessage msg, java.lang.String collectionName, long timeout, AdaptrisMessage reply) throws ProduceException
- Specified by:
doRequest
in classMongoDBProducer
- Throws:
ProduceException
-
retrieveResults
protected abstract com.mongodb.client.MongoIterable<org.bson.Document> retrieveResults(com.mongodb.client.MongoCollection<org.bson.Document> collection, AdaptrisMessage msg) throws InterlokException
- Throws:
InterlokException
-
getBatchSize
public java.lang.Integer getBatchSize()
-
setBatchSize
public void setBatchSize(java.lang.Integer batchSize)
-
getJsonOutputSettings
public JsonOutputSettings getJsonOutputSettings()
-
setJsonOutputSettings
public void setJsonOutputSettings(JsonOutputSettings jsonOutputSettings)
-
-