クラス BarrierSpec

java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec < BarrierSpec、reacters.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