クラス JmsInboundGateway
java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.gateway.MessagingGatewaySupport
org.springframework.integration.jms.inbound.JmsInboundGateway
- 実装済みのインターフェース一覧:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle, ComponentSourceAware, ExpressionCapable, OrderlyShutdownCapable, IntegrationPattern, NamedComponent, IntegrationInboundManagement, IntegrationManagement, ManageableLifecycle, ManageableSmartLifecycle, TrackableComponent
MessagingGatewaySupport を実装する JmsMessageDrivenEndpoint のラッパー。- 導入:
- 7.0
- 作成者:
- Artem Bilan, Gary Russell
ネストされたクラスの概要
クラス MessagingGatewaySupport から継承されたネストクラス / インターフェース
MessagingGatewaySupport.ConvertingMessagingTemplateインターフェース IntegrationManagement から継承されたネストクラス / インターフェース
IntegrationManagement.ManagementOverridesフィールド概要
クラス MessagingGatewaySupport から継承されたフィールド
messagingTemplateクラス AbstractEndpoint から継承されたフィールド
lifecycleLockクラス IntegrationObjectSupport から継承されたフィールド
EXPRESSION_PARSER, loggerインターフェース IntegrationManagement から継承されたフィールド
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAMEインターフェース SmartLifecycle から継承されたフィールド
DEFAULT_PHASEコンストラクター概要
コンストラクターコンストラクター説明JmsInboundGateway(AbstractMessageListenerContainer listenerContainer, ChannelPublishingJmsMessageListener listener) 方法の概要
修飾子と型メソッド説明intスケジューラー、エグゼキューターなどの通常のシャットダウンの後、シャットダウン遅延が経過した後、残りのアクティブなスケジューラー / エグゼキュータースレッドの強制シャットダウンの前に呼び出されます。オプションで、まだ処理中のアクティブなメッセージの数を返すことができます。intシャットダウンが始まる前に呼び出されます。voiddestroy()protected voiddoStart()サブクラスは、開始動作でこのメソッドを実装する必要があります。protected voiddoStop()サブクラスは、停止動作でこのメソッドを実装する必要があります。protected voidonInit()サブクラスは、初期化ロジック用にこれを実装できます。voidregisterMetricsCaptor(MetricsCaptor metricsCaptorToRegister) MetricsCaptorを注入します。voidregisterObservationRegistry(io.micrometer.observation.ObservationRegistry observationRegistry) ObservationRegistryを注入します。voidsetApplicationContext(ApplicationContext applicationContext) voidsetBeanFactory(BeanFactory beanFactory) voidsetErrorChannel(MessageChannel errorChannel) エラーチャンネルを設定します。voidsetErrorChannelName(StringSE errorChannelName) エラーチャネル名を設定します。voidsetErrorOnTimeout(boolean errorOnTimeout) errorOnTimeout が true の場合、応答が期待されても何も受信されない場合に、MessageTimeoutExceptionペイロードを含むErrorMessageをエラーチャネルに送信するインスタンスを作成します。voidsetObservationConvention(@Nullable MessageRequestReplyReceiverObservationConvention observationConvention) voidsetReplyChannel(MessageChannel replyChannel) 返信チャンネルを設定します。voidsetReplyChannelName(StringSE replyChannelName) 返信チャンネル名を設定します。voidsetReplyTimeout(long replyTimeout) 応答メッセージを受信するためのタイムアウト値を設定します。voidsetRequestChannel(MessageChannel requestChannel) リクエストチャネルを設定します。voidsetRequestChannelName(StringSE requestChannelName) リクエストチャンネル名を設定します。voidsetRequestTimeout(long requestTimeout) リクエストメッセージを送信するためのタイムアウト値を設定します。voidsetShouldTrack(boolean shouldTrack) このゲートウェイを、送信または sendAndReceive 操作から生成されたメッセージのメッセージ履歴で追跡するかどうかを指定します。voidsetShutdownContainerOnStop(boolean shutdownContainerOnStop) エンドポイントが停止しているときにリスナーコンテナーがシャットダウンしないようにするには、falseに設定します。クラス MessagingGatewaySupport から継承されたメソッド
buildErrorMessage, buildSendTimer, getErrorChannel, getErrorMessageAttributes, getErrorMessageStrategy, getIntegrationPatternType, getManagedName, getManagedType, getOverrides, getReplyChannel, getRequestChannel, getRequestChannelName, isLoggingEnabled, isObserved, receive, receive, receiveMessage, receiveMessage, registerReplyMessageCorrelatorIfNecessary, send, sendAndReceive, sendAndReceiveMessage, sendAndReceiveMessageReactive, sendTimer, setErrorMessageStrategy, setLoggingEnabled, setManagedName, setManagedType, setReceiverObservationConvention, setReplyMapper, setRequestMapperクラス AbstractEndpoint から継承されたメソッド
doStop, getPhase, getRole, isActive, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stopクラス IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentDescription, getComponentName, getComponentSource, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, setBeanName, setChannelResolver, setComponentDescription, setComponentName, setComponentSource, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringクラス ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, wait, waitSE, waitSEインターフェース IntegrationManagement から継承されたメソッド
getThisAsインターフェース NamedComponent から継承されたメソッド
getBeanName, getComponentNameインターフェース SmartLifecycle から継承されたメソッド
isPauseable
コンストラクターの詳細
JmsInboundGateway
public JmsInboundGateway(AbstractMessageListenerContainer listenerContainer, ChannelPublishingJmsMessageListener listener)
方法の詳細
setRequestChannel
クラスからコピーされた説明:MessagingGatewaySupportリクエストチャネルを設定します。- オーバーライド:
- クラス
MessagingGatewaySupportのsetRequestChannel - パラメーター:
requestChannel- リクエストメッセージの送信先のチャネル
setRequestChannelName
クラスからコピーされた説明:MessagingGatewaySupportリクエストチャンネル名を設定します。- オーバーライド:
- クラス
MessagingGatewaySupportのsetRequestChannelName - パラメーター:
requestChannelName- リクエストメッセージの送信先となるチャネル Bean 名
setReplyChannel
クラスからコピーされた説明:MessagingGatewaySupport返信チャンネルを設定します。応答チャネルが提供されていない場合、このゲートウェイは常に匿名の一時チャネルを使用して応答を処理します。- オーバーライド:
- クラス
MessagingGatewaySupportのsetReplyChannel - パラメーター:
replyChannel- 返信メッセージの受信元のチャネル
setReplyChannelName
クラスからコピーされた説明:MessagingGatewaySupport返信チャンネル名を設定します。応答チャネルが提供されていない場合、このゲートウェイは常に匿名の一時チャネルを使用して応答を処理します。- オーバーライド:
- クラス
MessagingGatewaySupportのsetReplyChannelName - パラメーター:
replyChannelName- 応答メッセージの受信元となるチャネル Bean 名
setErrorChannel
クラスからコピーされた説明:MessagingGatewaySupportエラーチャネルを設定します。エラーチャネルが指定されていない場合、このゲートウェイは呼び出し元に例外を伝播します。例外を完全に抑制するには、ここで "nullChannel" への参照を指定します。- オーバーライド:
- クラス
MessagingGatewaySupportのsetErrorChannel - パラメーター:
errorChannel- エラーチャネル。
setErrorChannelName
クラスからコピーされた説明:MessagingGatewaySupportエラーチャネル名を設定します。エラーチャネルが指定されていない場合、このゲートウェイは呼び出し元に例外を伝播します。例外を完全に抑制するには、ここで "nullChannel" への参照を指定します。- オーバーライド:
- クラス
MessagingGatewaySupportのsetErrorChannelName - パラメーター:
errorChannelName- エラーチャネル Bean 名。
setRequestTimeout
public void setRequestTimeout(long requestTimeout) クラスからコピーされた説明:MessagingGatewaySupportリクエストメッセージを送信するためのタイムアウト値を設定します。明示的に設定されていない場合、デフォルトは 1 秒です。- オーバーライド:
- クラス
MessagingGatewaySupportのsetRequestTimeout - パラメーター:
requestTimeout- ミリ秒単位のタイムアウト値
setReplyTimeout
public void setReplyTimeout(long replyTimeout) クラスからコピーされた説明:MessagingGatewaySupport応答メッセージを受信するためのタイムアウト値を設定します。明示的に設定されていない場合、デフォルトは 1 秒です。- オーバーライド:
- クラス
MessagingGatewaySupportのsetReplyTimeout - パラメーター:
replyTimeout- ミリ秒単位のタイムアウト値
setErrorOnTimeout
public void setErrorOnTimeout(boolean errorOnTimeout) クラスからコピーされた説明:MessagingGatewaySupporterrorOnTimeout が true の場合、応答が期待されても何も受信されない場合に、MessageTimeoutExceptionペイロードを含むErrorMessageをエラーチャネルに送信するインスタンスを作成します。エラーチャネルが設定されていない場合、MessageTimeoutExceptionがスローされます。- オーバーライド:
- クラス
MessagingGatewaySupportのsetErrorOnTimeout - パラメーター:
errorOnTimeout- true の場合、応答タイムアウト時にエラーメッセージを作成します。
setShouldTrack
public void setShouldTrack(boolean shouldTrack) クラスからコピーされた説明:MessagingGatewaySupportこのゲートウェイを、送信または sendAndReceive 操作から生成されたメッセージのメッセージ履歴で追跡するかどうかを指定します。- 次で指定:
- インターフェース
TrackableComponent内のsetShouldTrack - オーバーライド:
- クラス
MessagingGatewaySupportのsetShouldTrack
setShutdownContainerOnStop
public void setShutdownContainerOnStop(boolean shutdownContainerOnStop) エンドポイントの停止時にリスナーコンテナーがシャットダウンしないようにするには、falseに設定します。そのように設定されている場合、コンテナー内にキャッシュされたコンシューマーはそのまま残ります。そうでない場合、共有接続が閉じられ、リスナー呼び出し側がシャットダウンされます。この動作はバージョン 5.1 以降で新しく追加されました。デフォルト: true。- パラメーター:
shutdownContainerOnStop- シャットダウンしない場合は false。- 導入:
- 5.1
registerMetricsCaptor
インターフェースからコピーされた説明:IntegrationManagementMetricsCaptorを注入します。ObservationRegistryが指定されている場合は無視されます。- 次で指定:
- インターフェース
IntegrationManagement内のregisterMetricsCaptor - オーバーライド:
- クラス
MessagingGatewaySupportのregisterMetricsCaptor - パラメーター:
metricsCaptorToRegister- キャプター。- 関連事項:
registerObservationRegistry
public void registerObservationRegistry(io.micrometer.observation.ObservationRegistry observationRegistry) インターフェースからコピーされた説明:IntegrationManagementObservationRegistryを注入します。指定された場合、MetricsCaptorは無視されます。メーターのキャプチャーは、提供されたObservationRegistryでObservationHandlerとして構成する必要があります。- 次で指定:
- インターフェース
IntegrationManagement内のregisterObservationRegistry - オーバーライド:
- クラス
MessagingGatewaySupportのregisterObservationRegistry - パラメーター:
observationRegistry- コンポーネントからの観測結果を公開するObservationRegistry。- 関連事項:
setObservationConvention
public void setObservationConvention(@Nullable MessageRequestReplyReceiverObservationConvention observationConvention) - オーバーライド:
- クラス
MessagingGatewaySupportのsetObservationConvention
getComponentType
- 次で指定:
- インターフェース
NamedComponent内のgetComponentType - オーバーライド:
- クラス
MessagingGatewaySupportのgetComponentType
setApplicationContext
- 次で指定:
- インターフェース
ApplicationContextAware内のsetApplicationContext - オーバーライド:
- クラス
IntegrationObjectSupportのsetApplicationContext - 例外:
BeansException
setBeanFactory
- 次で指定:
- インターフェース
BeanFactoryAware内のsetBeanFactory - オーバーライド:
- クラス
IntegrationObjectSupportのsetBeanFactory
onInit
protected void onInit()クラスからコピーされた説明:IntegrationObjectSupportサブクラスは、初期化ロジック用にこれを実装できます。- オーバーライド:
- クラス
MessagingGatewaySupportのonInit
getListener
doStart
protected void doStart()クラスからコピーされた説明:AbstractEndpointサブクラスは、開始動作でこのメソッドを実装する必要があります。このメソッドは、AbstractEndpoint.lifecycleLockを保持しているときに呼び出されます。- オーバーライド:
- クラス
MessagingGatewaySupportのdoStart
doStop
protected void doStop()クラスからコピーされた説明:AbstractEndpointサブクラスは、停止動作でこのメソッドを実装する必要があります。このメソッドは、AbstractEndpoint.lifecycleLockを保持しているときに呼び出されます。- オーバーライド:
- クラス
MessagingGatewaySupportのdoStop
destroy
public void destroy()- 次で指定:
- インターフェース
DisposableBean内のdestroy - 次で指定:
- インターフェース
IntegrationManagement内のdestroy - オーバーライド:
- クラス
MessagingGatewaySupportのdestroy
beforeShutdown
public int beforeShutdown()インターフェースからコピーされた説明:OrderlyShutdownCapableシャットダウンが始まる前に呼び出されます。実装は、新しいメッセージの受け入れを停止する必要があります。オプションで、処理中のアクティブなメッセージの数を返すことができます。- 次で指定:
- インターフェース
OrderlyShutdownCapable内のbeforeShutdown - 戻り値:
- 使用可能な場合、アクティブなメッセージの数。
afterShutdown
public int afterShutdown()インターフェースからコピーされた説明:OrderlyShutdownCapableスケジューラー、エグゼキューターなどの通常のシャットダウンの後、シャットダウン遅延が経過した後、残りのアクティブなスケジューラー / エグゼキュータースレッドの強制シャットダウンの前に呼び出されます。オプションで、まだ処理中のアクティブなメッセージの数を返すことができます。- 次で指定:
- インターフェース
OrderlyShutdownCapable内のafterShutdown - 戻り値:
- 使用可能な場合、アクティブなメッセージの数。