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

クラス SubscribableRedisChannel

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.channel.AbstractMessageChannel
org.springframework.integration.redis.channel.SubscribableRedisChannel
実装されたすべてのインターフェース:
Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、Lifecycle、Phased、SmartLifecycle、BroadcastCapableChannel、ExpressionCapable、IntegrationPattern、NamedComponent、IntegrationManagement、ManageableLifecycle、ManageableSmartLifecycle、TrackableComponent、MessageChannel、SubscribableChannel、InterceptableChannel
public class SubscribableRedisChannel extends AbstractMessageChannel implements BroadcastCapableChannel, ManageableSmartLifecycle
Redis トピックからメッセージを消費するための pub-sub セマンティクスを提供する BroadcastCapableChannel アスペクトを備えた AbstractMessageChannel 実装。
導入:
2.0
作成者:
Oleg Zhurakousky, Gary Russell, Artem Bilan

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

  • メソッドの詳細

    • setTaskExecutor

      public void setTaskExecutor(ExecutorSE taskExecutor)

    • setMessageConverter

      public void setMessageConverter(MessageConverter messageConverter)
      クラスからコピーされた説明: AbstractMessageChannel
      ペイロードがまだ一致していないメッセージに対して、このチャネルでサポートされているデータ型の 1 つに（順番に）変換しようとするときに使用する MessageConverter を指定します。

      注意 : MessageConverter.fromMessage(Message, Class) メソッドのみが使用されます。返されたオブジェクトが Message でない場合、受信ヘッダーがコピーされます。返されたオブジェクトが Message の場合、コンバーターはヘッダーに完全に入力されていると予想されます。チャネルはそれ以上のアクションを実行しません。null が返されると、次のデータ型（存在する場合）への変換が試行されます。デフォルトは DefaultDatatypeChannelMessageConverter です。

      オーバーライド:
      クラス AbstractMessageChannel の setMessageConverter 
      パラメーター:
      messageConverter - メッセージコンバーター。

    • setSerializer

      public void setSerializer(RedisSerializer<?> serializer)

    • setMaxSubscribers

      public void setMaxSubscribers(int maxSubscribers)
      チャネルのディスパッチャーがサポートするサブスクライバの最大数を指定します。
      パラメーター:
      maxSubscribers - 許可されるサブスクライバーの最大数。

    • subscribe

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

    • unsubscribe

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

    • doSend

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

    • onInit

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

    • isAutoStartup

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

    • getPhase

      public int getPhase()
      次で指定:
      インターフェース Phased の getPhase 
      次で指定:
      インターフェース SmartLifecycle の getPhase 

    • isRunning

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

    • start

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

    • stop

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

    • stop

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

    • destroy

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