public class JpaOutboundGateway extends AbstractReplyProducingMessageHandler
OutboundGatewayType
に応じて、送信ゲートウェイは JpaExecutor
のポーリングメソッドまたはその executeOutboundJpaOperation メソッドのいずれかを使用します。アダプターを初期化するには、コンストラクターとして JpaExecutor
を提供する必要があります。AbstractReplyProducingMessageHandler.RequestHandler
IntegrationManagement.ManagementOverrides
messagingTemplate
EXPRESSION_PARSER, logger
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
コンストラクターと説明 |
---|
JpaOutboundGateway(JpaExecutor jpaExecutor) すべての JPA 操作をラップする JpaExecutor を取得するコンストラクター。 |
修飾子と型 | メソッドと説明 |
---|---|
protected void | doInit() |
StringSE | getComponentType() サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。 |
protected ObjectSE | handleRequestMessage(Message<?> requestMessage) サブクラスはこのメソッドを実装して、リクエストメッセージを処理する必要があります。 |
void | setGatewayType(OutboundGatewayType gatewayType) JpaOutboundGateway モードを指定します。 |
void | setProducesReply(boolean producesReply) 'false' に設定すると、このコンポーネントは送信チャネルアダプターとして機能します。 |
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, 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 JpaOutboundGateway(JpaExecutor jpaExecutor)
JpaExecutor
を取得するコンストラクター。jpaExecutor
- null であってはなりません public StringSE getComponentType()
IntegrationObjectSupport
NamedComponent
の getComponentType
MessageHandlerSupport
の getComponentType
protected void doInit()
AbstractReplyProducingMessageHandler
の doInit
protected ObjectSE handleRequestMessage(Message<?> requestMessage)
AbstractReplyProducingMessageHandler
AbstractReplyProducingMessageHandler
の handleRequestMessage
requestMessage
- リクエストメッセージ。null
public void setGatewayType(OutboundGatewayType gatewayType)
JpaOutboundGateway
モードを指定します。gatewayType
- ゲートウェイ型。public void setProducesReply(boolean producesReply)
producesReply
- デフォルトは "true" です。