クラス FluxMessageChannel

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.channel.AbstractMessageChannel
org.springframework.integration.channel.FluxMessageChannel
実装済みのインターフェース一覧:
org.reactivestreams.Publisher<Message<?>>、Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、Lifecycle、ReactiveStreamsSubscribableChannel、ComponentSourceAware、ExpressionCapable、IntegrationPattern、NamedComponent、IntegrationManagement、TrackableComponent、MessageChannel、InterceptableChannel
public class FluxMessageChannel extends AbstractMessageChannel implements org.reactivestreams.Publisher<Message<?>>, ReactiveStreamsSubscribableChannel, Lifecycle
プロジェクト Reactor Flux に基づく Reactive Streams Publisher の AbstractMessageChannel 実装。

このクラスは、このチャネルが再起動されたときに、subscribeTo(Publisher) を介して接続されたパブリッシャーへのサブスクリプションを制御するために Lifecycle を実装します。

導入:
5.0
作成者:
Artem Bilan, Gary Russell, Sergei Egorov

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

    • FluxMessageChannel

      public FluxMessageChannel()

  • メソッドの詳細

    • doSend

      protected boolean doSend(Message<?> message, long timeout)
      クラスからコピーされた説明: AbstractMessageChannel
      サブクラスはこのメソッドを実装する必要があります。負でないタイムアウトは、チャネルが容量に達した場合に待機する時間を示します（値が 0 の場合、成功の有無にかかわらずすぐに戻る必要があります）。負のタイムアウト値は、メッセージが受け入れられるか、ブロッキングスレッドが中断されるまでメソッドがブロックされることを示します。
      次で指定:
      クラス AbstractMessageChannel の doSend 
      パラメーター:
      message - メッセージ。
      timeout - タイムアウト。
      戻り値:
      send が成功した場合は true。

    • subscribe

      public void subscribe(org.reactivestreams.Subscriber<? super Message<?>> subscriber)
      次で指定:
      インターフェース org.reactivestreams.Publisher<Message<?>> の subscribe 

    • start

      public void start()
      次で指定:
      インターフェース Lifecycle の start 

    • stop

      public void stop()
      次で指定:
      インターフェース Lifecycle の stop 

    • isRunning

      public boolean isRunning()
      次で指定:
      インターフェース Lifecycle の isRunning 

    • subscribeTo

      public void subscribeTo(org.reactivestreams.Publisher<? extends Message<?>> publisher)
      次で指定:
      インターフェース ReactiveStreamsSubscribableChannel の subscribeTo 

    • destroy

      public void destroy()
      次で指定:
      インターフェース DisposableBean の destroy 
      次で指定:
      インターフェース IntegrationManagement の destroy 
      オーバーライド:
      クラス AbstractMessageChannel の destroy