public class MongoDbOutboundGateway extends AbstractReplyProducingMessageHandler
MongoOperationsAbstractReplyProducingMessageHandler.RequestHandlerIntegrationManagement.ManagementOverridesmessagingTemplateEXPRESSION_PARSER, loggerMETER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME| Constructor and Description |
|---|
MongoDbOutboundGateway(org.springframework.data.mongodb.MongoDbFactory mongoDbFactory) |
MongoDbOutboundGateway(org.springframework.data.mongodb.MongoDbFactory mongoDbFactory,
org.springframework.data.mongodb.core.convert.MongoConverter mongoConverter) |
MongoDbOutboundGateway(org.springframework.data.mongodb.core.MongoOperations mongoTemplate) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
doInit() |
protected java.lang.Object |
handleRequestMessage(org.springframework.messaging.Message<?> requestMessage)
Subclasses must implement this method to handle the request Message.
|
void |
setCollectionCallback(org.springframework.data.mongodb.core.CollectionCallback<?> collectionCallback)
Deprecated.
in favor of
setMessageCollectionCallback(MessageCollectionCallback).
Will be removed in 5.2 |
void |
setCollectionNameExpression(org.springframework.expression.Expression collectionNameExpression) |
void |
setCollectionNameExpressionString(java.lang.String collectionNameExpressionString) |
void |
setEntityClass(java.lang.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(org.springframework.data.mongodb.core.convert.MongoConverter mongoConverter) |
void |
setQueryExpression(org.springframework.expression.Expression queryExpression) |
void |
setQueryExpressionString(java.lang.String queryExpressionString) |
doInvokeAdvisedRequestHandler, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReplyaddNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeadersconfigureMetrics, destroy, getActiveCount, getActiveCountLong, getComponentType, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onComplete, onError, onNext, onSubscribe, registerMetricsCaptor, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabledafterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetComponentNamepublic MongoDbOutboundGateway(org.springframework.data.mongodb.MongoDbFactory mongoDbFactory)
public MongoDbOutboundGateway(org.springframework.data.mongodb.MongoDbFactory mongoDbFactory,
org.springframework.data.mongodb.core.convert.MongoConverter mongoConverter)
public MongoDbOutboundGateway(org.springframework.data.mongodb.core.MongoOperations mongoTemplate)
public void setQueryExpression(org.springframework.expression.Expression queryExpression)
public void setQueryExpressionString(java.lang.String queryExpressionString)
@Deprecated public void setCollectionCallback(org.springframework.data.mongodb.core.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(java.lang.Class<?> entityClass)
public void setCollectionNameExpression(org.springframework.expression.Expression collectionNameExpression)
public void setCollectionNameExpressionString(java.lang.String collectionNameExpressionString)
public void setMongoConverter(org.springframework.data.mongodb.core.convert.MongoConverter mongoConverter)
protected void doInit()
doInit in class AbstractReplyProducingMessageHandlerprotected java.lang.Object handleRequestMessage(org.springframework.messaging.Message<?> requestMessage)
AbstractReplyProducingMessageHandlerhandleRequestMessage in class AbstractReplyProducingMessageHandlerrequestMessage - The request message.null.