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

クラス SubscribableKafkaChannel

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.channel.AbstractMessageChannel
org.springframework.integration.kafka.channel.AbstractKafkaChannel
org.springframework.integration.kafka.channel.SubscribableKafkaChannel
実装されたすべてのインターフェース:
Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、Lifecycle、Phased、SmartLifecycle、ExpressionCapable、IntegrationPattern、NamedComponent、IntegrationManagement、ManageableLifecycle、ManageableSmartLifecycle、TrackableComponent、MessageChannel、SubscribableChannel、InterceptableChannel
既知の直属サブクラス
PublishSubscribeKafkaChannel
public class SubscribableKafkaChannel extends AbstractKafkaChannel implements SubscribableChannel, ManageableSmartLifecycle
Apache Kafka トピックによる購読可能なチャンネル。
導入:
5.4
作成者:
Gary Russell, Artem Bilan

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

    • SubscribableKafkaChannel

      public SubscribableKafkaChannel(org.springframework.kafka.core.KafkaOperations<?,?> template, org.springframework.kafka.config.KafkaListenerContainerFactory<?> factory, StringSE channelTopic)
      提供されたパラメーターを使用してインスタンスを構築します。
      パラメーター:
      template - 送信用のテンプレート。
      factory - 受け取るためのコンテナーを作成するためのファクトリ。
      channelTopic - トピック。

  • メソッドの詳細

    • setMessageConverter

      public void setMessageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)
      RecordMessageConverter をリスナーに設定します。
      パラメーター:
      messageConverter - コンバーター。
      導入:
      6.0

    • getPhase

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

    • setPhase

      public void setPhase(int phase)
      フェーズを設定します。
      パラメーター:
      phase - フェーズ。
      関連事項:

    • isRunning

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

    • setAutoStartup

      public void setAutoStartup(boolean autoStartup)
      自動起動を設定します。
      パラメーター:
      autoStartup - 自動的に開始するには true。
      関連事項:

    • isAutoStartup

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

    • onInit

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

    • createDispatcher

      protected MessageDispatcher createDispatcher()

    • start

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

    • stop

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

    • stop

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

    • subscribe

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

    • unsubscribe

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