パッケージ org.springframework.integration.channel

クラス AbstractSubscribableChannel

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.channel.AbstractMessageChannel
org.springframework.integration.channel.AbstractSubscribableChannel
実装されたすべてのインターフェース:
Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、ComponentSourceAware、ExpressionCapable、IntegrationPattern、NamedComponent、IntegrationManagement、SubscribableChannelManagement、TrackableComponent、MessageChannel、SubscribableChannel、InterceptableChannel
既知の直属サブクラス
AbstractExecutorChannel、DirectChannel、PostgresSubscribableChannel
public abstract class AbstractSubscribableChannel extends AbstractMessageChannel implements SubscribableChannel, SubscribableChannelManagement
MessageDispatcher に委譲することにより、サブスクライブされた handler(s) を呼び出す MessageChannel の基本実装。
作成者:
Mark Fisher, Oleg Zhurakousky, Gary Russell, Artme Bilan

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

    • AbstractSubscribableChannel

      public AbstractSubscribableChannel()

  • メソッドの詳細

    • getSubscriberCount

      public int getSubscriberCount()
      インターフェースからコピーされた説明: SubscribableChannelManagement
      このチャネルに現在サブスクライブしているメッセージハンドラーの数。
      次で指定:
      インターフェース SubscribableChannelManagement の getSubscriberCount 
      戻り値:
      サブスクライバーの数。

    • subscribe

      public boolean subscribe(MessageHandler handler)
      次で指定:
      インターフェース SubscribableChannel の subscribe 

    • unsubscribe

      public boolean unsubscribe(MessageHandler handle)
      次で指定:
      インターフェース SubscribableChannel の unsubscribe 

    • doSend

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

    • getDispatcher

      protected abstract MessageDispatcher getDispatcher()