public class MongoDbOutboundGateway extends AbstractReplyProducingMessageHandler
MongoOperations
AbstractReplyProducingMessageHandler.RequestHandler
IntegrationManagement.ManagementOverrides
messagingTemplate
EXPRESSION_PARSER, logger
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
Constructor and Description |
---|
MongoDbOutboundGateway(MongoDbFactory mongoDbFactory) |
MongoDbOutboundGateway(MongoDbFactory mongoDbFactory,
MongoConverter mongoConverter) |
MongoDbOutboundGateway(MongoOperations mongoTemplate) |
Modifier and Type | Method and Description |
---|---|
protected void |
doInit() |
protected Object |
handleRequestMessage(Message<?> requestMessage)
Subclasses must implement this method to handle the request Message.
|
void |
setCollectionCallback(CollectionCallback<?> collectionCallback)
Deprecated.
in favor of
setMessageCollectionCallback(MessageCollectionCallback) .
Will be removed in 5.2 |
void |
setCollectionNameExpression(Expression collectionNameExpression) |
void |
setCollectionNameExpressionString(String collectionNameExpressionString) |
void |
setEntityClass(Class<?> entityClass) |
void |
setExpectSingleResult(boolean expectSingleResult) |
void |
setMessageCollectionCallback(MessageCollectionCallback<?> collectionCallback)
Specify a
MessageCollectionCallback to perform against MongoDB collection
in the request message context. |
void |
setMongoConverter(MongoConverter mongoConverter) |
void |
setQueryExpression(Expression queryExpression) |
void |
setQueryExpressionString(String queryExpressionString) |
doInvokeAdvisedRequestHandler, getBeanClassLoader, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReply
addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, messageBuilderForReply, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeaders
configureMetrics, destroy, getActiveCount, getActiveCountLong, getComponentType, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMetricsCaptor, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onComplete, onError, onNext, onSubscribe, registerMetricsCaptor, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
errorCount, handleCount
getBeanName, getComponentName
public MongoDbOutboundGateway(MongoDbFactory mongoDbFactory)
public MongoDbOutboundGateway(MongoDbFactory mongoDbFactory, MongoConverter mongoConverter)
public MongoDbOutboundGateway(MongoOperations mongoTemplate)
public void setQueryExpression(Expression queryExpression)
public void setQueryExpressionString(String queryExpressionString)
@Deprecated public void setCollectionCallback(CollectionCallback<?> collectionCallback)
setMessageCollectionCallback(MessageCollectionCallback)
.
Will be removed in 5.2CollectionCallback
to perform against MongoDB collection.collectionCallback
- the callback to perform against MongoDB collection.public void setMessageCollectionCallback(MessageCollectionCallback<?> collectionCallback)
MessageCollectionCallback
to perform against MongoDB collection
in the request message context.collectionCallback
- the callback to perform against MongoDB collection.public void setExpectSingleResult(boolean expectSingleResult)
public void setEntityClass(Class<?> entityClass)
public void setCollectionNameExpression(Expression collectionNameExpression)
public void setCollectionNameExpressionString(String collectionNameExpressionString)
public void setMongoConverter(MongoConverter mongoConverter)
protected void doInit()
doInit
in class AbstractReplyProducingMessageHandler
protected Object handleRequestMessage(Message<?> requestMessage)
AbstractReplyProducingMessageHandler
handleRequestMessage
in class AbstractReplyProducingMessageHandler
requestMessage
- The request message.null
.