Package com.adaptris.core.mongodb
Class MongoDBUpdateReplaceProducer
- 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.MongoDBArrayProducer
-
- com.adaptris.core.mongodb.MongoDBUpdateReplaceProducer
-
- All Implemented Interfaces:
AdaptrisComponent
,AdaptrisMessageProducer
,AdaptrisMessageSender
,AdaptrisMessageWorker
,ComponentLifecycle
,ComponentLifecycleExtension
,MessageEventGenerator
- Direct Known Subclasses:
MongoDBReplaceProducer
,MongoDBUpdateProducer
public abstract class MongoDBUpdateReplaceProducer extends MongoDBArrayProducer
-
-
Field Summary
-
Fields inherited from class com.adaptris.core.AdaptrisMessageWorkerImp
log
-
-
Constructor Summary
Constructors Constructor Description MongoDBUpdateReplaceProducer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.Boolean
getBypassDocumentValidation()
java.util.List<java.lang.String>
getFilterFields()
java.lang.Boolean
getUpsert()
void
parseAndActionDocument(com.mongodb.client.MongoCollection<org.bson.Document> collection, AdaptrisMessage message)
void
setBypassDocumentValidation(java.lang.Boolean bypassDocumentValidation)
void
setFilterFields(java.util.List<java.lang.String> filterFields)
void
setUpsert(java.lang.Boolean upsert)
-
Methods inherited from class com.adaptris.core.mongodb.MongoDBArrayProducer
doRequest
-
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
-
parseAndActionDocument
public final void parseAndActionDocument(com.mongodb.client.MongoCollection<org.bson.Document> collection, AdaptrisMessage message) throws InterlokException
- Specified by:
parseAndActionDocument
in classMongoDBArrayProducer
- Throws:
InterlokException
-
getFilterFields
public java.util.List<java.lang.String> getFilterFields()
-
setFilterFields
public void setFilterFields(java.util.List<java.lang.String> filterFields)
-
getUpsert
public java.lang.Boolean getUpsert()
-
setUpsert
public void setUpsert(java.lang.Boolean upsert)
-
getBypassDocumentValidation
public java.lang.Boolean getBypassDocumentValidation()
-
setBypassDocumentValidation
public void setBypassDocumentValidation(java.lang.Boolean bypassDocumentValidation)
-
-