Package com.adaptris.core.mongodb

Class MongoDBProducer

java.lang.Object

com.adaptris.core.AdaptrisMessageWorkerImp

com.adaptris.core.AdaptrisMessageProducerImp

com.adaptris.core.RequestReplyProducerBase

com.adaptris.core.RequestReplyProducerImp

com.adaptris.core.mongodb.MongoDBProducer

All Implemented Interfaces:

AdaptrisComponent, AdaptrisMessageProducer, AdaptrisMessageSender, AdaptrisMessageWorker, ComponentLifecycle, ComponentLifecycleExtension, MessageEventGenerator

Direct Known Subclasses:

MongoDBArrayProducer, MongoDBRetrieveProducer, MongoDBUpdateDataTypesProducer

public abstract class MongoDBProducer
extends RequestReplyProducerImp

Field Summary

Fields inherited from class com.adaptris.core.AdaptrisMessageWorkerImp

log

Constructor Summary

Constructors

Constructor	Description
MongoDBProducer()

Method Summary

Modifier and Type	Method	Description
protected long	defaultTimeout()
protected void	doProduce(AdaptrisMessage msg, java.lang.String endpoint)
protected AdaptrisMessage	doRequest(AdaptrisMessage msg, java.lang.String endpoint, long timeout)
protected abstract AdaptrisMessage	doRequest(AdaptrisMessage msg, java.lang.String collection, long timeout, AdaptrisMessage reply)
java.lang.String	endpoint(AdaptrisMessage msg)
java.lang.String	getCollection()	The MongoDB collection name.
protected com.mongodb.MongoClient	getMongoClient()
protected com.mongodb.client.MongoDatabase	getMongoDatabase()
void	init()
void	prepare()
void	setCollection(java.lang.String collection)	The MongoDB collection name.
<T extends MongoDBProducer> T	withCollection(java.lang.String s)

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

MongoDBProducer

public MongoDBProducer()

Method Detail

prepare

public void prepare()

init

public void init()
          throws CoreException

Throws:

CoreException

doRequest

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

Specified by:

doRequest in class RequestReplyProducerImp

Throws:

ProduceException

doProduce

protected void doProduce(AdaptrisMessage msg,
                         java.lang.String endpoint)
                  throws ProduceException

Specified by:

doProduce in class RequestReplyProducerImp

Throws:

ProduceException

doRequest

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

Throws:

ProduceException

defaultTimeout

protected long defaultTimeout()

Specified by:

defaultTimeout in class RequestReplyProducerBase

getMongoClient

protected com.mongodb.MongoClient getMongoClient()

getMongoDatabase

protected com.mongodb.client.MongoDatabase getMongoDatabase()

endpoint

public java.lang.String endpoint(AdaptrisMessage msg)
                          throws ProduceException

Specified by:

endpoint in class AdaptrisMessageProducerImp

Throws:

ProduceException

withCollection

public <T extends MongoDBProducer> T withCollection(java.lang.String s)

getCollection

public java.lang.String getCollection()

The MongoDB collection name.

setCollection

public void setCollection(java.lang.String collection)

The MongoDB collection name.