@IntegrationManagedResource public abstract class MessagingGatewaySupport extends AbstractEndpoint implements TrackableComponent, IntegrationInboundManagement, IntegrationPattern
MessageChannel に接続するための便利な基本クラス。リクエストと応答の MessageChannel を構成するための setter と、メッセージを送受信するためのタイムアウト値を公開します。IntegrationManagement.ManagementOverrides| 修飾子と型 | フィールドと説明 |
|---|---|
protected MessagingTemplate | messagingTemplate |
lifecycleCondition, lifecycleLockEXPRESSION_PARSER, loggerMETER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAMEDEFAULT_PHASE| コンストラクターと説明 |
|---|
MessagingGatewaySupport() 応答がない場合に null を返すインスタンスを作成します。 |
MessagingGatewaySupport(boolean errorOnTimeout)errorOnTimeout が true の場合、応答が期待されても何も受信されない場合に、 MessageTimeoutException ペイロードを含む ErrorMessage をエラーチャネルに送信するインスタンスを作成します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected ErrorMessage | buildErrorMessage(Message<?> requestMessage, ThrowableSE throwable) メッセージのエラーメッセージを作成し、構成済みの ErrorMessageStrategy を使用してスロー可能にします。 |
protected TimerFacade | buildSendTimer(boolean success, StringSE exception) |
void | destroy() |
protected void | doStart() サブクラスは、開始動作でこのメソッドを実装する必要があります。 |
protected void | doStop() サブクラスは、停止動作でこのメソッドを実装する必要があります。 |
StringSE | getComponentType() サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。 |
MessageChannel | getErrorChannel() エラーメッセージがルーティングされるエラーチャネル(提供されている場合)を返します。 |
protected AttributeAccessor | getErrorMessageAttributes(Message<?> message)errorMessageStrategy でエラーメッセージを作成するときに使用する AttributeAccessor を設定します。 |
IntegrationPatternType | getIntegrationPatternType() このコンポーネントが実装するパターン型を返します。 |
StringSE | getManagedName() |
StringSE | getManagedType() |
IntegrationManagement.ManagementOverrides | getOverrides() オーバーライドを返します。 |
MessageChannel | getReplyChannel() このゲートウェイの応答チャネルがある場合はそれを返します。 |
MessageChannel | getRequestChannel() このゲートウェイのリクエストチャネルを返します。 |
boolean | isLoggingEnabled() ロギングが有効かどうかを返します。 |
protected void | onInit() サブクラスは、初期化ロジック用にこれを実装できます。 |
protected ObjectSE | receive() |
protected ObjectSE | receive(long timeout) |
protected Message<?> | receiveMessage() |
protected Message<?> | receiveMessage(long timeout) |
void | registerMetricsCaptor(MetricsCaptor metricsCaptorToRegister)MetricsCaptor を注入する |
protected void | registerReplyMessageCorrelatorIfNecessary() |
protected void | send(ObjectSE object) |
protected ObjectSE | sendAndReceive(ObjectSE object) |
protected Message<?> | sendAndReceiveMessage(ObjectSE object) |
protected reactor.core.publisher.Mono<Message<?>> | sendAndReceiveMessageReactive(ObjectSE object) |
protected TimerFacade | sendTimer() |
void | setErrorChannel(MessageChannel errorChannel) エラーチャンネルを設定します。 |
void | setErrorChannelName(StringSE errorChannelName) エラーチャネル名を設定します。 |
void | setErrorMessageStrategy(ErrorMessageStrategy errorMessageStrategy) 例外が発生したときにエラーメッセージを作成するために使用する ErrorMessageStrategy を設定します。 |
void | setErrorOnTimeout(boolean errorOnTimeout)errorOnTimeout が true の場合、応答が期待されても何も受信されない場合に、 MessageTimeoutException ペイロードを含む ErrorMessage をエラーチャネルに送信するインスタンスを作成します。 |
void | setLoggingEnabled(boolean enabled) ロギングを有効にするかどうか。 |
void | setManagedName(StringSE managedName) |
void | setManagedType(StringSE managedType) |
void | setReplyChannel(MessageChannel replyChannel) 返信チャンネルを設定します。 |
void | setReplyChannelName(StringSE replyChannelName) 返信チャンネル名を設定します。 |
void | setReplyMapper(OutboundMessageMapper<?> replyMapper) 受信または sendAndReceive 操作で受信した応答メッセージからオブジェクトにマッピングするための OutboundMessageMapper を提供します。 |
void | setReplyTimeout(long replyTimeout) 応答メッセージを受信するためのタイムアウト値を設定します。 |
void | setRequestChannel(MessageChannel requestChannel) リクエストチャネルを設定します。 |
void | setRequestChannelName(StringSE requestChannelName) リクエストチャンネル名を設定します。 |
void | setRequestMapper(InboundMessageMapper<?> requestMapper) 送信または sendAndReceive 操作で渡された任意のオブジェクトからリクエストメッセージを作成するための InboundMessageMapper を提供します。 |
void | setRequestTimeout(long requestTimeout) リクエストメッセージを送信するためのタイムアウト値を設定します。 |
void | setShouldTrack(boolean shouldTrack) このゲートウェイを、送信または sendAndReceive 操作から生成されたメッセージのメッセージ履歴で追跡するかどうかを指定します。 |
doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stopafterPropertiesSet, 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, toStringcloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSEgetThisAsgetBeanName, getComponentNameprotected final MessagingTemplate messagingTemplate
public MessagingGatewaySupport()
public MessagingGatewaySupport(boolean errorOnTimeout)
MessageTimeoutException ペイロードを含む ErrorMessage をエラーチャネルに送信するインスタンスを作成します。エラーチャネルが設定されていない場合、MessageTimeoutException がスローされます。errorOnTimeout - エラーメッセージを作成するには true。setErrorOnTimeout(boolean)public void setErrorOnTimeout(boolean errorOnTimeout)
MessageTimeoutException ペイロードを含む ErrorMessage をエラーチャネルに送信するインスタンスを作成します。エラーチャネルが設定されていない場合、MessageTimeoutException がスローされます。errorOnTimeout - true の場合、応答タイムアウト時にエラーメッセージを作成します。public void setRequestChannel(MessageChannel requestChannel)
requestChannel - リクエストメッセージの送信先のチャネル public void setRequestChannelName(StringSE requestChannelName)
requestChannelName - リクエストメッセージの送信先となるチャネル Bean 名 public void setReplyChannel(MessageChannel replyChannel)
replyChannel - 返信メッセージの受信元のチャネル public void setReplyChannelName(StringSE replyChannelName)
replyChannelName - 応答メッセージの受信元となるチャネル Bean 名 public void setErrorChannel(MessageChannel errorChannel)
errorChannel - エラーチャネル。public void setErrorChannelName(StringSE errorChannelName)
errorChannelName - エラーチャネル Bean 名。public void setRequestTimeout(long requestTimeout)
requestTimeout - ミリ秒単位のタイムアウト値 public void setReplyTimeout(long replyTimeout)
replyTimeout - ミリ秒単位のタイムアウト値 public void setRequestMapper(@Nullable InboundMessageMapper<?> requestMapper)
InboundMessageMapper を提供します。requestMapper - リクエストマッパー。public void setReplyMapper(OutboundMessageMapper<?> replyMapper)
OutboundMessageMapper を提供します。replyMapper - 返信マッパー。public void setShouldTrack(boolean shouldTrack)
TrackableComponent の setShouldTrack public StringSE getComponentType()
IntegrationObjectSupportNamedComponent の getComponentType IntegrationObjectSupport の getComponentType public void setLoggingEnabled(boolean enabled)
IntegrationManagementIntegrationManagement の setLoggingEnabled enabled - 無効にする dalse。public boolean isLoggingEnabled()
IntegrationManagementIntegrationManagement の isLoggingEnabled public final void setErrorMessageStrategy(ErrorMessageStrategy errorMessageStrategy)
ErrorMessageStrategy を設定します。デフォルトは DefaultErrorMessageStrategy です。errorMessageStrategy - ErrorMessageStrategypublic IntegrationManagement.ManagementOverrides getOverrides()
IntegrationManagementIntegrationManagement の getOverrides public void setManagedType(StringSE managedType)
IntegrationManagement の setManagedType public StringSE getManagedType()
IntegrationManagement の getManagedType public void setManagedName(StringSE managedName)
IntegrationManagement の setManagedName public StringSE getManagedName()
IntegrationManagement の getManagedName public IntegrationPatternType getIntegrationPatternType()
IntegrationPatternIntegrationPattern の getIntegrationPatternType IntegrationPatternTypepublic void registerMetricsCaptor(MetricsCaptor metricsCaptorToRegister)
IntegrationManagementMetricsCaptor を注入する IntegrationManagement の registerMetricsCaptor metricsCaptorToRegister - キャプター。protected void onInit()
IntegrationObjectSupportAbstractEndpoint の onInit @Nullable public MessageChannel getRequestChannel()
@Nullable public MessageChannel getReplyChannel()
@Nullable public MessageChannel getErrorChannel()
protected void send(ObjectSE object)
protected reactor.core.publisher.Mono<Message<?>> sendAndReceiveMessageReactive(ObjectSE object)
protected TimerFacade sendTimer()
protected TimerFacade buildSendTimer(boolean success, StringSE exception)
protected final ErrorMessage buildErrorMessage(@Nullable Message<?> requestMessage, ThrowableSE throwable)
ErrorMessageStrategy を使用してスロー可能にします。requestMessage - requestMessage。throwable - スローアブル。protected AttributeAccessor getErrorMessageAttributes(@Nullable Message<?> message)
errorMessageStrategy でエラーメッセージを作成するときに使用する AttributeAccessor を設定します。message - メッセージ。protected void registerReplyMessageCorrelatorIfNecessary()
protected void doStart()
AbstractEndpointAbstractEndpoint.lifecycleLock を保持しているときに呼び出されます。AbstractEndpoint の doStart protected void doStop()
AbstractEndpointAbstractEndpoint.lifecycleLock を保持しているときに呼び出されます。AbstractEndpoint の doStop public void destroy()
DisposableBean の destroy IntegrationManagement の destroy AbstractEndpoint の destroy