public class StoredProcOutboundGateway extends AbstractReplyProducingMessageHandler
AbstractReplyProducingMessageHandler
実装。AbstractReplyProducingMessageHandler.RequestHandler
IntegrationManagement.ManagementOverrides
messagingTemplate
EXPRESSION_PARSER, logger
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
コンストラクターと説明 |
---|
StoredProcOutboundGateway(StoredProcExecutor storedProcExecutor) StoredProcExecutor をとるコンストラクター。 |
修飾子と型 | メソッドと説明 |
---|---|
protected void | doInit() |
StringSE | getComponentType() サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。 |
protected ObjectSE | handleRequestMessage(Message<?> requestMessage) サブクラスはこのメソッドを実装して、リクエストメッセージを処理する必要があります。 |
void | setExpectSingleResult(boolean expectSingleResult) このパラメーターは、ストアードプロシージャー / 関数呼び出しから 1 つの結果オブジェクトのみが返されることを示します。 |
void | setRequiresReply(boolean requiresReply) 返信が必要かどうかのフラグ。 |
doInvokeAdvisedRequestHandler, getBeanClassLoader, getIntegrationPatternType, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader
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, 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 StoredProcOutboundGateway(StoredProcExecutor storedProcExecutor)
StoredProcExecutor
をとるコンストラクター。storedProcExecutor
- null であってはなりません。public void setRequiresReply(boolean requiresReply)
AbstractReplyProducingMessageHandler
AbstractReplyProducingMessageHandler
の setRequiresReply
requiresReply
- 返信が必要な場合は true。public void setExpectSingleResult(boolean expectSingleResult)
true
に設定すると、1 つの要素のみを含む resultMap
は、その 1 つの要素を抽出し、ペイロードとして返します。resultMap
に複数の要素と expectSingleResult == true
が含まれている場合、MessagingException
がスローされます。
それ以外の場合は、完全な resultMap
が Message
ペイロードとして返されます。
重要な注意点: H2 などのいくつかのデータベースは完全にはサポートされていません。たとえば、H2 データベースは CallableStatement
SE セマンティクスを完全にはサポートしておらず、H2 に対して関数呼び出しを実行すると、単一の値ではなく結果リストが返されます。
expectSingleResult = true
を設定しても、コレクションが返される場合があります。
true
に設定すると、setRequiresReply(boolean)
も true
で呼び出されます。これは、正確に単一の結果が期待され、null
が適切な値ではないことを示します。null
の結果の場合、ReplyRequiredException
がスローされます。
expectSingleResult
- 単一の結果が期待される場合は true。public StringSE getComponentType()
IntegrationObjectSupport
NamedComponent
の getComponentType
MessageHandlerSupport
の getComponentType
protected void doInit()
AbstractReplyProducingMessageHandler
の doInit
protected ObjectSE handleRequestMessage(Message<?> requestMessage)
AbstractReplyProducingMessageHandler
AbstractReplyProducingMessageHandler
の handleRequestMessage
requestMessage
- リクエストメッセージ。null