org.springframework.integration.jms.inbound.JmsMessageDrivenEndpoint

実装されているすべてのインターフェース:: Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、SmartInitializingSingleton、ApplicationContextAware、Lifecycle、Phased、SmartLifecycle、ComponentSourceAware、ExpressionCapable、OrderlyShutdownCapable、MessageProducer、IntegrationPattern、NamedComponent、IntegrationInboundManagement、IntegrationManagement、ManageableLifecycle、ManageableSmartLifecycle、TrackableComponent

既知の直属サブクラス: JmsMessageDrivenEndpoint

public class JmsMessageDrivenEndpoint extends MessageProducerSupport implements OrderlyShutdownCapable

JMS メッセージを受信し、Spring Integration メッセージに変換して、結果をチャネルに送信するメッセージ駆動型エンドポイント。

作成者:: Mark Fisher, Oleg Zhurakousky, Gary Russell, Artem Bilan

ネストされたクラスの要約
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース
IntegrationManagement.ManagementOverrides
フィールドのサマリー
クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたフィールド
lifecycleLock
クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド
EXPRESSION_PARSER, logger
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド
DEFAULT_PHASE
コンストラクターの概要
コンストラクター
コンストラクター
説明
JmsMessageDrivenEndpoint(AbstractMessageListenerContainer listenerContainer, ChannelPublishingJmsMessageListener listener)
外部で構成されたコンテナーを使用してインスタンスを作成します。
メソッドのサマリー
修飾子と型
メソッド
説明
int
afterShutdown()
スケジューラー、エグゼキューターなどの通常のシャットダウンの後、シャットダウン遅延が経過した後、残りのアクティブなスケジューラー / エグゼキュータースレッドの強制シャットダウンの前に呼び出されます。オプションで、まだ処理中のアクティブなメッセージの数を返すことができます。
void
afterSingletonsInstantiated()
int
beforeShutdown()
シャットダウンが始まる前に呼び出されます。
void
destroy()
protected void
doStart()
デフォルトでは何もしません。
protected void
doStop()
デフォルトでは何もしません。
StringSE
getComponentType()
ChannelPublishingJmsMessageListener
getListener()
protected void
onInit()
サブクラスは、初期化ロジック用にこれを実装できます。
void
registerMetricsCaptor(MetricsCaptor captor)
MetricsCaptor を注入します。
void
registerObservationRegistry(io.micrometer.observation.ObservationRegistry observationRegistry)
ObservationRegistry を注入します。
void
setApplicationContext(ApplicationContext applicationContext)
void
setErrorChannel(MessageChannel errorChannel)
void
setErrorChannelName(StringSE errorChannelName)
エラーチャネル名を設定します。
void
setErrorMessageStrategy(ErrorMessageStrategy errorMessageStrategy)
例外が発生したときにエラーメッセージを作成するために使用する ErrorMessageStrategy を設定します。
void
setObservationConvention(@Nullable MessageReceiverObservationConvention observationConvention)
IntegrationObservation.HANDLER にカスタム MessageReceiverObservationConvention を設定します。
void
setOutputChannel(MessageChannel outputChannel)
生成されたメッセージの送信先となる MessageChannel を指定します。
void
setOutputChannelName(StringSE outputChannelName)
出力チャネル名を設定します。提供されている場合、outputChannel をオーバーライドします。
void
setSendTimeout(long sendTimeout)
送信操作に使用するデフォルトのタイムアウト値を構成します。
void
setSessionAcknowledgeMode(StringSE sessionAcknowledgeMode)
リスナーコンテナーにセッション確認応答モードを設定します。
void
setShouldTrack(boolean shouldTrack)
void
setShutdownContainerOnStop(boolean shutdownContainerOnStop)
エンドポイントが停止しているときにリスナーコンテナーがシャットダウンしないようにするには、false に設定します。
クラス org.springframework.integration.endpoint.MessageProducerSupport から継承されたメソッド
buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getErrorMessageStrategy, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, getRequiredOutputChannel, isObserved, sendErrorMessageIfNecessary, sendMessage, subscribeToPublisher
クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたメソッド
doStop, getPhase, getRole, isActive, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop
クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentDescription, getComponentName, getComponentSource, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, setBeanFactory, setBeanName, setChannelResolver, setComponentDescription, setComponentName, setComponentSource, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, wait, waitSE, waitSE
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド
getManagedName, getManagedType, getOverrides, getThisAs, isLoggingEnabled, setLoggingEnabled, setManagedName, setManagedType
インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド
getBeanName, getComponentName
インターフェース org.springframework.context.SmartLifecycle から継承されたメソッド
isPauseable

コンストラクターの詳細
- JmsMessageDrivenEndpoint
  public JmsMessageDrivenEndpoint(AbstractMessageListenerContainer listenerContainer, ChannelPublishingJmsMessageListener listener)
  外部で構成されたコンテナーを使用してインスタンスを作成します。
  パラメーター:
  listenerContainer - コンテナー。
  listener - リスナー。
メソッドの詳細
- setSessionAcknowledgeMode
  public void setSessionAcknowledgeMode(StringSE sessionAcknowledgeMode)
  リスナーコンテナーでセッション確認モードを設定します。外部コンテナーが提供されている場合でも、コンテナー設定を上書きします。外部コンテナーが提供されている場合はデフォルトで null（コンテナーを変更しない）、またはフレームワークが暗黙の DefaultMessageListenerContainer を作成する場合は `transacted`。
  パラメーター:
  sessionAcknowledgeMode - 承認モード。
- setOutputChannel
  public void setOutputChannel(MessageChannel outputChannel)
  インターフェースからコピーされた説明: MessageProducer
  生成されたメッセージの送信先となる MessageChannel を指定します。
  次で指定:
  インターフェース MessageProducer の setOutputChannel
  オーバーライド:
  クラス MessageProducerSupport の setOutputChannel
  パラメーター:
  outputChannel - 出力チャネル。
- setOutputChannelName
  public void setOutputChannelName(StringSE outputChannelName)
  クラスからコピーされた説明: MessageProducerSupport
  出力チャネル名を設定します。提供されている場合、outputChannel をオーバーライドします。
  次で指定:
  インターフェース MessageProducer の setOutputChannelName
  オーバーライド:
  クラス MessageProducerSupport の setOutputChannelName
  パラメーター:
  outputChannelName - チャンネル名。
- setErrorChannel
  public void setErrorChannel(MessageChannel errorChannel)
  オーバーライド:
  クラス MessageProducerSupport の setErrorChannel
- setErrorChannelName
  public void setErrorChannelName(StringSE errorChannelName)
  クラスからコピーされた説明: MessageProducerSupport
  エラーチャネル名を設定します。エラーチャネルが指定されていない場合、このエンドポイントは例外をメッセージ駆動型ソースに伝播します。例外を完全に抑制するには、ここで "nullChannel" への参照を指定します。
  オーバーライド:
  クラス MessageProducerSupport の setErrorChannelName
  パラメーター:
  errorChannelName - エラーチャネル Bean 名。
- setSendTimeout
  public void setSendTimeout(long sendTimeout)
  クラスからコピーされた説明: MessageProducerSupport
  送信操作に使用するデフォルトのタイムアウト値を構成します。個々のメッセージに対してオーバーライドされる場合があります。
  オーバーライド:
  クラス MessageProducerSupport の setSendTimeout
  パラメーター:
  sendTimeout - 「送信」操作のタイムアウト (ミリ秒)
  関連事項:
  GenericMessagingTemplate.setSendTimeout(long)
- setShouldTrack
  public void setShouldTrack(boolean shouldTrack)
  次で指定:
  インターフェース TrackableComponent の setShouldTrack
  オーバーライド:
  クラス MessageProducerSupport の setShouldTrack
- setErrorMessageStrategy
  public void setErrorMessageStrategy(ErrorMessageStrategy errorMessageStrategy)
  クラスからコピーされた説明: MessageProducerSupport
  例外が発生したときにエラーメッセージを作成するために使用する ErrorMessageStrategy を設定します。デフォルトは DefaultErrorMessageStrategy です。
  オーバーライド:
  クラス MessageProducerSupport の setErrorMessageStrategy
  パラメーター:
  errorMessageStrategy - ErrorMessageStrategy
- setShutdownContainerOnStop
  public void setShutdownContainerOnStop(boolean shutdownContainerOnStop)
  エンドポイントの停止時にリスナーコンテナーがシャットダウンしないようにするには、false に設定します。そのように設定されている場合、コンテナー内にキャッシュされたコンシューマーはそのまま残ります。そうでない場合、共有接続が閉じられ、リスナー呼び出し側がシャットダウンされます。この動作はバージョン 5.1 以降で新しく追加されました。デフォルト: true。
  パラメーター:
  shutdownContainerOnStop - シャットダウンしない場合は false。
  導入:
  5.1
- getListener
  public ChannelPublishingJmsMessageListener getListener()
- registerMetricsCaptor
  public void registerMetricsCaptor(MetricsCaptor captor)
  インターフェースからコピーされた説明: IntegrationManagement
  MetricsCaptor を注入します。ObservationRegistry が指定されている場合は無視されます。
  次で指定:
  インターフェース IntegrationManagement の registerMetricsCaptor
  パラメーター:
  captor - キャプター。
  関連事項:
  IntegrationManagement.registerObservationRegistry(ObservationRegistry)
- registerObservationRegistry
  public void registerObservationRegistry(io.micrometer.observation.ObservationRegistry observationRegistry)
  インターフェースからコピーされた説明: IntegrationManagement
  ObservationRegistry を注入します。指定された場合、MetricsCaptor は無視されます。メーターのキャプチャーは、提供された ObservationRegistry で ObservationHandler として構成する必要があります。
  次で指定:
  インターフェース IntegrationManagement の registerObservationRegistry
  オーバーライド:
  クラス MessageProducerSupport の registerObservationRegistry
  パラメーター:
  observationRegistry - コンポーネントからの観測結果を公開する ObservationRegistry。
  関連事項:
  IntegrationManagement.registerMetricsCaptor(MetricsCaptor)
- setObservationConvention
  public void setObservationConvention(@Nullable MessageReceiverObservationConvention observationConvention)
  クラスからコピーされた説明: MessageProducerSupport
  IntegrationObservation.HANDLER にカスタム MessageReceiverObservationConvention を設定します。このコンポーネントに対して ObservationRegistry が構成されていない場合は無視されます。
  オーバーライド:
  クラス MessageProducerSupport の setObservationConvention
  パラメーター:
  observationConvention - 使用する MessageReceiverObservationConvention。
- setApplicationContext
  public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
  次で指定:
  インターフェース ApplicationContextAware の setApplicationContext
  オーバーライド:
  クラス IntegrationObjectSupport の setApplicationContext
  例外:
  BeansException
- getComponentType
  public StringSE getComponentType()
  次で指定:
  インターフェース NamedComponent の getComponentType
  オーバーライド:
  クラス MessageProducerSupport の getComponentType
- afterSingletonsInstantiated
  public void afterSingletonsInstantiated()
  次で指定:
  インターフェース SmartInitializingSingleton の afterSingletonsInstantiated
  オーバーライド:
  クラス MessageProducerSupport の afterSingletonsInstantiated
- onInit
  protected void onInit()
  クラスからコピーされた説明: IntegrationObjectSupport
  サブクラスは、初期化ロジック用にこれを実装できます。
  オーバーライド:
  クラス MessageProducerSupport の onInit
- doStart
  protected void doStart()
  クラスからコピーされた説明: MessageProducerSupport
  デフォルトでは何も実行されません。ライフサイクル管理された動作が必要な場合、サブクラスはこれをオーバーライドできます。'lifecycleLock' によって保護されています。
  オーバーライド:
  クラス MessageProducerSupport の doStart
- doStop
  protected void doStop()
  クラスからコピーされた説明: MessageProducerSupport
  デフォルトでは何もしません。サブクラスは、ライフサイクル管理の動作が必要な場合、これをオーバーライドできます。
  オーバーライド:
  クラス MessageProducerSupport の doStop
- destroy
  public void destroy()
  次で指定:
  インターフェース DisposableBean の destroy
  次で指定:
  インターフェース IntegrationManagement の destroy
  オーバーライド:
  クラス AbstractEndpoint の destroy
- beforeShutdown
  public int beforeShutdown()
  インターフェースからコピーされた説明: OrderlyShutdownCapable
  シャットダウンが始まる前に呼び出されます。実装は、新しいメッセージの受け入れを停止する必要があります。オプションで、処理中のアクティブなメッセージの数を返すことができます。
  次で指定:
  インターフェース OrderlyShutdownCapable の beforeShutdown
  戻り値:
  使用可能な場合、アクティブなメッセージの数。
- afterShutdown
  public int afterShutdown()
  インターフェースからコピーされた説明: OrderlyShutdownCapable
  スケジューラー、エグゼキューターなどの通常のシャットダウンの後、シャットダウン遅延が経過した後、残りのアクティブなスケジューラー / エグゼキュータースレッドの強制シャットダウンの前に呼び出されます。オプションで、まだ処理中のアクティブなメッセージの数を返すことができます。
  次で指定:
  インターフェース OrderlyShutdownCapable の afterShutdown
  戻り値:
  使用可能な場合、アクティブなメッセージの数。

クラス JmsMessageDrivenEndpoint

ネストされたクラスの要約

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース

フィールドのサマリー

クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたフィールド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド

インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド

コンストラクターの概要

メソッドのサマリー

クラス org.springframework.integration.endpoint.MessageProducerSupport から継承されたメソッド

クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたメソッド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド

クラス java.lang.ObjectSE から継承されたメソッド

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド

インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド

インターフェース org.springframework.context.SmartLifecycle から継承されたメソッド

コンストラクターの詳細

JmsMessageDrivenEndpoint

メソッドの詳細

setSessionAcknowledgeMode

setOutputChannel

setOutputChannelName

setErrorChannel

setErrorChannelName

setSendTimeout

setShouldTrack

setErrorMessageStrategy

setShutdownContainerOnStop

getListener

registerMetricsCaptor

registerObservationRegistry

setObservationConvention

setApplicationContext

getComponentType

afterSingletonsInstantiated

onInit

doStart

doStop

destroy

beforeShutdown

afterShutdown