public class MongoDbOutboundGateway extends AbstractReplyProducingMessageHandler
MongoOperations
を使用して MongoDb データベースを照会する送信操作を行います AbstractReplyProducingMessageHandler.RequestHandler
IntegrationManagement.ManagementOverrides
messagingTemplate
EXPRESSION_PARSER, logger
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
コンストラクターと説明 |
---|
MongoDbOutboundGateway(MongoDatabaseFactory mongoDbFactory) |
MongoDbOutboundGateway(MongoDatabaseFactory mongoDbFactory, MongoConverter mongoConverter) |
MongoDbOutboundGateway(MongoOperations mongoTemplate) |
修飾子と型 | メソッドと説明 |
---|---|
protected void | doInit() |
protected ObjectSE | handleRequestMessage(Message<?> requestMessage) サブクラスはこのメソッドを実装して、リクエストメッセージを処理する必要があります。 |
void | setCollectionNameExpression(Expression collectionNameExpression) |
void | setCollectionNameExpressionString(StringSE collectionNameExpressionString) |
void | setEntityClass(ClassSE<?> entityClass) |
void | setExpectSingleResult(boolean expectSingleResult) |
void | setMessageCollectionCallback(MessageCollectionCallback<?> collectionCallback) リクエストメッセージコンテキストで MongoDB コレクションに対して実行する MessageCollectionCallback を指定します。 |
void | setMongoConverter(MongoConverter mongoConverter) |
void | setQueryExpression(Expression queryExpression) |
void | setQueryExpressionString(StringSE queryExpressionString) |
doInvokeAdvisedRequestHandler, getBeanClassLoader, getIntegrationPatternType, 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
handleMessage, onComplete, onError, onNext, onSubscribe
buildSendTimer, destroy, getComponentType, getManagedName, getManagedType, getMetricsCaptor, getOrder, getOverrides, isLoggingEnabled, registerMetricsCaptor, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrack
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
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE
getThisAs
getBeanName, getComponentName
public MongoDbOutboundGateway(MongoDatabaseFactory mongoDbFactory)
public MongoDbOutboundGateway(MongoDatabaseFactory mongoDbFactory, MongoConverter mongoConverter)
public MongoDbOutboundGateway(MongoOperations mongoTemplate)
public void setQueryExpression(Expression queryExpression)
public void setQueryExpressionString(StringSE queryExpressionString)
public void setMessageCollectionCallback(MessageCollectionCallback<?> collectionCallback)
MessageCollectionCallback
を指定します。collectionCallback
- MongoDB コレクションに対して実行するコールバック。public void setExpectSingleResult(boolean expectSingleResult)
public void setEntityClass(ClassSE<?> entityClass)
public void setCollectionNameExpression(Expression collectionNameExpression)
public void setCollectionNameExpressionString(StringSE collectionNameExpressionString)
public void setMongoConverter(MongoConverter mongoConverter)
protected void doInit()
AbstractReplyProducingMessageHandler
の doInit
protected ObjectSE handleRequestMessage(Message<?> requestMessage)
AbstractReplyProducingMessageHandler
AbstractReplyProducingMessageHandler
の handleRequestMessage
requestMessage
- リクエストメッセージ。null