クラス BarrierSpec

java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec<BarrierSpec, reactor.util.function.Tuple2<ConsumerEndpointFactoryBean, BarrierMessageHandler>>
org.springframework.integration.dsl.EndpointSpec<BarrierSpec, ConsumerEndpointFactoryBean, BarrierMessageHandler>
org.springframework.integration.dsl.ConsumerEndpointSpec<BarrierSpec, BarrierMessageHandler>
org.springframework.integration.dsl.BarrierSpec
実装済みのインターフェース一覧:
DisposableBean, FactoryBean<reactor.util.function.Tuple2<ConsumerEndpointFactoryBean, BarrierMessageHandler>>, InitializingBean, Lifecycle, Phased, SmartLifecycle, ComponentsRegistration
public class BarrierSpec extends ConsumerEndpointSpec<BarrierSpec, BarrierMessageHandler>
BarrierMessageHandler の MessageHandlerSpec。
導入:
5.0
作成者:
Artem Bilan

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

    • BarrierSpec

      protected BarrierSpec(long timeout)

  • 方法の詳細

    • outputProcessor

      public BarrierSpec outputProcessor(MessageGroupProcessor outputProcessor)

    • correlationStrategy

      public BarrierSpec correlationStrategy(CorrelationStrategy correlationStrategy)

    • discardChannel

      public BarrierSpec discardChannel(@Nullable MessageChannel discardChannel)
      遅れて到着したトリガーメッセージが送信されるチャネル、またはリクエストメッセージが時間内に到着しないチャネルを設定します。
      パラメーター:
      discardChannel - 破棄されたトリガーのメッセージチャネル。
      戻り値:
      スペック
      導入:
      6.2.10

    • discardChannel

      public BarrierSpec discardChannel(@Nullable StringSE discardChannelName)
      遅れて到着したトリガーメッセージが送信されるチャネル、またはリクエストメッセージが時間内に到着しないチャネル Bean 名を設定します。
      パラメーター:
      discardChannelName - 破棄されたトリガーのメッセージチャネル。
      戻り値:
      スペック
      導入:
      6.2.10

    • triggerTimeout

      public BarrierSpec triggerTimeout(long triggerTimeout)
      リクエストメッセージを待機するときのタイムアウトをミリ秒単位で設定します。
      パラメーター:
      triggerTimeout - リクエストメッセージを待機するときのミリ秒単位のタイムアウト。
      戻り値:
      スペック
      導入:
      6.2.10

    • doGet

      public reactor.util.function.Tuple2<ConsumerEndpointFactoryBean, BarrierMessageHandler> doGet()
      オーバーライド:
      クラス ConsumerEndpointSpec<BarrierSpec, BarrierMessageHandler> の doGet