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

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

Constructor Detail

MongoDBUpdateDataTypesProducer

public MongoDBUpdateDataTypesProducer()

Method Detail

doRequest

protected AdaptrisMessage doRequest(AdaptrisMessage msg,
                                    java.lang.String collectionName,
                                    long timeout,
                                    AdaptrisMessage reply)
                             throws ProduceException

Specified by:

doRequest in class MongoDBProducer

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)