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

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

Constructor Detail

MongoDBUpdateReplaceProducer

public MongoDBUpdateReplaceProducer()

Method Detail

parseAndActionDocument

public final void parseAndActionDocument(com.mongodb.client.MongoCollection<org.bson.Document> collection,
                                         AdaptrisMessage message)
                                  throws InterlokException

Specified by:

parseAndActionDocument in class MongoDBArrayProducer

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)