public class MongoDbOutboundGateway extends AbstractReplyProducingMessageHandler
MongoOperations
AbstractReplyProducingMessageHandler.RequestHandler
IntegrationManagement.ManagementOverrides
messagingTemplate
EXPRESSION_PARSER, logger
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) |
void |
setCollectionNameExpression(org.springframework.expression.Expression collectionNameExpression) |
void |
setCollectionNameExpressionString(java.lang.String collectionNameExpressionString) |
void |
setEntityClass(java.lang.Class<?> entityClass) |
void |
setExpectSingleResult(boolean expectSingleResult) |
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, setRequiresReply
addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput
configureMetrics, getActiveCount, getActiveCountLong, getComponentType, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onComplete, onError, onNext, onSubscribe, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getComponentName
public 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)
public void setCollectionCallback(org.springframework.data.mongodb.core.CollectionCallback<?> collectionCallback)
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 AbstractReplyProducingMessageHandler
protected java.lang.Object handleRequestMessage(org.springframework.messaging.Message<?> requestMessage)
AbstractReplyProducingMessageHandler
handleRequestMessage
in class AbstractReplyProducingMessageHandler
requestMessage
- The request message.null
.