Package com.adaptris.core.mongodb
Class MongoDBUpdateDataTypesProducer
- 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.MongoDBUpdateDataTypesProducer
-
- All Implemented Interfaces:
AdaptrisComponent
,AdaptrisMessageProducer
,AdaptrisMessageSender
,AdaptrisMessageWorker
,ComponentLifecycle
,ComponentLifecycleExtension
,MessageEventGenerator
@ComponentProfile(summary="Update data types in MongoDB.", tag="producer,mongodb", recommended=MongoDBConnection.class) public class MongoDBUpdateDataTypesProducer extends MongoDBProducer
In the adapter configuration file this class is aliased as mongodb-update-data-types-producer which is the preferred alternative to the fully qualified classname when building your configuration.
-
-
Field Summary
-
Fields inherited from class com.adaptris.core.AdaptrisMessageWorkerImp
log
-
-
Constructor Summary
Constructors Constructor Description MongoDBUpdateDataTypesProducer()
-
Method Summary
All Methods Instance 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()
DataInputParameter<java.lang.String>
getFilter()
java.util.List<ValueConverter>
getValueConverters()
void
setBatchSize(java.lang.Integer batchSize)
void
setFilter(DataInputParameter<java.lang.String> filter)
void
setValueConverters(java.util.List<ValueConverter> valueConverters)
MongoDBUpdateDataTypesProducer
withFilter(DataInputParameter<java.lang.String> filter)
MongoDBUpdateDataTypesProducer
withTypeConverters(java.util.List<ValueConverter> valueConverters)
-
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 AdaptrisMessage doRequest(AdaptrisMessage msg, java.lang.String collectionName, long timeout, AdaptrisMessage reply) throws ProduceException
- Specified by:
doRequest
in classMongoDBProducer
- Throws:
ProduceException
-
getFilter
public DataInputParameter<java.lang.String> getFilter()
-
setFilter
public void setFilter(DataInputParameter<java.lang.String> filter)
-
getValueConverters
public java.util.List<ValueConverter> getValueConverters()
-
setValueConverters
public void setValueConverters(java.util.List<ValueConverter> valueConverters)
-
getBatchSize
public java.lang.Integer getBatchSize()
-
setBatchSize
public void setBatchSize(java.lang.Integer batchSize)
-
withFilter
public MongoDBUpdateDataTypesProducer withFilter(DataInputParameter<java.lang.String> filter)
-
withTypeConverters
public MongoDBUpdateDataTypesProducer withTypeConverters(java.util.List<ValueConverter> valueConverters)
-
-