クラス SourcePollingChannelAdapter

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.endpoint.AbstractPollingEndpoint
org.springframework.integration.endpoint.SourcePollingChannelAdapter
実装されているすべてのインターフェース:
Aware、BeanClassLoaderAware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、Lifecycle、Phased、SmartLifecycle、ComponentSourceAware、ExpressionCapable、NamedComponent、IntegrationManagement、ManageableLifecycle、ManageableSmartLifecycle、TrackableComponent
public class SourcePollingChannelAdapter extends AbstractPollingEndpoint implements TrackableComponent, IntegrationManagement
MessageSource を MessageChannel に接続するためのチャネルアダプターの実装。
作成者:
Mark Fisher, Oleg Zhurakousky, Gary Russell, Artem Bilan, Christian Tzolov

  • コンストラクターの詳細

    • SourcePollingChannelAdapter

      public SourcePollingChannelAdapter()

  • メソッドの詳細

    • setSource

      public void setSource(MessageSource<?> source)
      メッセージをポーリングするソースを指定します。
      パラメーター:
      source - メッセージソース。

    • setOutputChannel

      public void setOutputChannel(MessageChannel outputChannel)
      メッセージの送信先である MessageChannel を指定します。
      パラメーター:
      outputChannel - 出力チャネル。

    • getMessageSource

      public MessageSource<?> getMessageSource()
      このエンドポイントのソースを返します。
      戻り値:
      ソース。
      導入:
      4.3

    • setOutputChannelName

      public void setOutputChannelName(StringSE outputChannelName)

    • setSendTimeout

      public void setSendTimeout(long sendTimeout)
      メッセージが出力チャネルに送信されるのを待機する最大時間を指定します。
      パラメーター:
      sendTimeout - 送信タイムアウト。

    • setShouldTrack

      public void setShouldTrack(boolean shouldTrack)
      このコンポーネントをメッセージ履歴で追跡するかどうかを指定します。
      次で指定:
      インターフェース TrackableComponent の setShouldTrack 
      パラメーター:
      shouldTrack - コンポーネントを追跡する必要がある場合は true。

    • registerObservationRegistry

      public void registerObservationRegistry(io.micrometer.observation.ObservationRegistry observationRegistry)
      インターフェースからコピーされた説明: IntegrationManagement
      ObservationRegistry を注入します。指定された場合、MetricsCaptor は無視されます。メーターのキャプチャーは、提供された ObservationRegistry で ObservationHandler として構成する必要があります。
      次で指定:
      インターフェース IntegrationManagement の registerObservationRegistry 
      パラメーター:
      observationRegistry - コンポーネントからの観測結果を公開する ObservationRegistry。
      関連事項:

    • setObservationConvention

      public void setObservationConvention(@Nullable MessageReceiverObservationConvention observationConvention)
      IntegrationObservation.HANDLER にカスタム MessageReceiverObservationConvention を設定します。このコンポーネントに対して ObservationRegistry が構成されていない場合は無視されます。
      パラメーター:
      observationConvention - 使用する MessageReceiverObservationConvention。
      導入:
      6.5

    • isObserved

      public boolean isObserved()
      インターフェースからコピーされた説明: IntegrationManagement
      この実装が ObservationRegistry.NOOP インスタンス以外のレジストリを処理する場合は true。
      次で指定:
      インターフェース IntegrationManagement の isObserved 
      戻り値:
      この実装が ObservationRegistry.NOOP インスタンス以外のレジストリを処理する場合は true。

    • getComponentType

      public StringSE getComponentType()
      次で指定:
      インターフェース NamedComponent の getComponentType 

    • isReactive

      protected boolean isReactive()
      オーバーライド:
      クラス AbstractPollingEndpoint の isReactive 

    • getReceiveMessageSource

      protected ObjectSE getReceiveMessageSource()
      オーバーライド:
      クラス AbstractPollingEndpoint の getReceiveMessageSource 

    • setReceiveMessageSource

      protected final void setReceiveMessageSource(ObjectSE source)
      オーバーライド:
      クラス AbstractPollingEndpoint の setReceiveMessageSource 

    • doStart

      protected void doStart()
      クラスからコピーされた説明: AbstractEndpoint
      サブクラスは、開始動作でこのメソッドを実装する必要があります。このメソッドは、AbstractEndpoint.lifecycleLock を保持しているときに呼び出されます。
      オーバーライド:
      クラス AbstractPollingEndpoint の doStart 

    • doStop

      protected void doStop()
      クラスからコピーされた説明: AbstractEndpoint
      サブクラスは、停止動作でこのメソッドを実装する必要があります。このメソッドは、AbstractEndpoint.lifecycleLock を保持しているときに呼び出されます。
      オーバーライド:
      クラス AbstractPollingEndpoint の doStop 

    • onInit

      protected void onInit()
      クラスからコピーされた説明: IntegrationObjectSupport
      サブクラスは、初期化ロジック用にこれを実装できます。
      オーバーライド:
      クラス AbstractPollingEndpoint の onInit 

    • getOutputChannel

      public MessageChannel getOutputChannel()

    • handleMessage

      protected void handleMessage(Message<?> messageArg)
      クラスからコピーされた説明: AbstractPollingEndpoint
      メッセージを処理します。
      次で指定:
      クラス AbstractPollingEndpoint の handleMessage 
      パラメーター:
      messageArg - メッセージ。

    • receiveMessage

      protected @Nullable Message<?> receiveMessage()
      クラスからコピーされた説明: AbstractPollingEndpoint
      次のメッセージを取得します（利用可能な場合）。すぐに利用できるメッセージがない場合は、null を返す場合があります。
      次で指定:
      クラス AbstractPollingEndpoint の receiveMessage 
      戻り値:
      メッセージまたは null。

    • messageReceived

      protected void messageReceived(@Nullable IntegrationResourceHolder holder, Message<?> message)
      受信したメッセージの観測を開始し、スコープを開きます。
      オーバーライド:
      クラス AbstractPollingEndpoint の messageReceived 
      パラメーター:
      holder - このコンポーネントのリソースホルダー。
      message - 受信したメッセージ。

    • donePollingTask

      protected void donePollingTask(@Nullable Message<?> message)
      以前に messageReceived(IntegrationResourceHolder, Message) から開始した観測を停止し (そのスコープを閉じます)。
      オーバーライド:
      クラス AbstractPollingEndpoint の donePollingTask 
      パラメーター:
      message - 受信メッセージ。null にすることができますが、この実装では無視されます。

    • getResourceToBind

      protected ObjectSE getResourceToBind()
      クラスからコピーされた説明: AbstractPollingEndpoint
      トランザクション同期を使用するときにバインドするリソース (MessageSource など) を返します。
      オーバーライド:
      クラス AbstractPollingEndpoint の getResourceToBind 
      戻り値:
      リソース。トランザクションの同期が不要な場合は null。

    • getResourceKey

      protected StringSE getResourceKey()
      クラスからコピーされた説明: AbstractPollingEndpoint
      リソースが IntegrationResourceHolder の属性として使用可能になるキーを返します。デフォルトの ExpressionEvaluatingTransactionSynchronizationProcessor は、この属性を SpEL 式の変数として使用できるようにします。
      オーバーライド:
      クラス AbstractPollingEndpoint の getResourceKey 
      戻り値:
      キー。リソースを属性として使用できない場合は null (デフォルト)。