SubscribableKafkaChannel (Spring Integration API)

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
```
Kafka トピックによるサブスクライブ可能なチャネル。
導入:
5.4
作成者:
Gary Russell, Artem Bilan

ネストされたクラスのサマリー
- クラス org.springframework.integration.channel.AbstractMessageChannel から継承されたネストクラス / インターフェース
  AbstractMessageChannel.ChannelInterceptorList
- インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース
  IntegrationManagement.ManagementOverrides

フィールドのサマリー
- クラス org.springframework.integration.kafka.channel.AbstractKafkaChannel から継承されたフィールド
  topic
- クラス org.springframework.integration.channel.AbstractMessageChannel から継承されたフィールド
  interceptors, meters
- クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド
  EXPRESSION_PARSER, logger
- インターフェース org.springframework.messaging.MessageChannel から継承されたフィールド
  INDEFINITE_TIMEOUT
- インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド
  METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

コンストラクターの概要

コンストラクター
コンストラクターと説明
`SubscribableKafkaChannel(org.springframework.kafka.core.KafkaOperations<?,?> template, org.springframework.kafka.config.KafkaListenerContainerFactory<?> factory, StringSE channelTopic)` 提供されたパラメーターを使用してインスタンスを構築します。

メソッドのサマリー

すべてのメソッドインスタンスメソッド具象メソッド
修飾子と型	メソッドと説明
`protected MessageDispatcher`	`createDispatcher()`
`int`	`getPhase()`
`boolean`	`isAutoStartup()`
`boolean`	`isRunning()`
`protected void`	`onInit()` サブクラスは、初期化ロジック用にこれを実装できます。
`void`	`setAutoStartup(boolean autoStartup)` 自動起動を設定します。
`void`	`setPhase(int phase)` フェーズを設定します。
`void`	`start()`
`void`	`stop()`
`void`	`stop(RunnableSE callback)`
`boolean`	`subscribe(MessageHandler handler)`
`boolean`	`unsubscribe(MessageHandler handler)`

クラス org.springframework.integration.kafka.channel.AbstractKafkaChannel から継承されたメソッド
doSend, getGroupId, setGroupId

クラス org.springframework.integration.channel.AbstractMessageChannel から継承されたメソッド
addInterceptor, addInterceptor, destroy, getComponentType, getFullChannelName, getIChannelInterceptorList, getIntegrationPatternType, getInterceptors, getMetricsCaptor, getOverrides, isLoggingEnabled, registerMetricsCaptor, removeInterceptor, removeInterceptor, send, send, setDatatypes, setInterceptors, setLoggingEnabled, setMessageConverter, setShouldTrack

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

クラス java.lang.ObjectSE から継承されたメソッド
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE

インターフェース org.springframework.messaging.MessageChannel から継承されたメソッド
send, send

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド
getManagedName, getManagedType, getThisAs, setManagedName, setManagedType

インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド
getBeanName, getComponentName

- コンストラクターの詳細
  - SubscribableKafkaChannel
```
public SubscribableKafkaChannel(org.springframework.kafka.core.KafkaOperations<?,?> template,
                                org.springframework.kafka.config.KafkaListenerContainerFactory<?> factory,
                                StringSE channelTopic)
```
    提供されたパラメーターを使用してインスタンスを構築します。
    パラメーター:
    template - 送信用のテンプレート。
    factory - 受け取るためのコンテナーを作成するためのファクトリ。
    channelTopic - トピック。
- メソッドの詳細
  - getPhase
```
public int getPhase()
```
    次で指定:
    インターフェース Phased の getPhase
    次で指定:
    インターフェース SmartLifecycle の getPhase
  - setPhase
```
public void setPhase(int phase)
```
    フェーズを設定します。
    パラメーター:
    phase - フェーズ。
    関連事項:
    Phased
  - isRunning
```
public boolean isRunning()
```
    次で指定:
    インターフェース Lifecycle の isRunning
    次で指定:
    インターフェース ManageableLifecycle の isRunning
  - setAutoStartup
```
public void setAutoStartup(boolean autoStartup)
```
    自動起動を設定します。
    パラメーター:
    autoStartup - 自動的に開始するには true。
    関連事項:
    SmartLifecycle
  - 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

クラス SubscribableKafkaChannel

ネストされたクラスのサマリー

クラス org.springframework.integration.channel.AbstractMessageChannel から継承されたネストクラス / インターフェース

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース

フィールドのサマリー

クラス org.springframework.integration.kafka.channel.AbstractKafkaChannel から継承されたフィールド

クラス org.springframework.integration.channel.AbstractMessageChannel から継承されたフィールド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド

インターフェース org.springframework.messaging.MessageChannel から継承されたフィールド

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド

コンストラクターの概要

メソッドのサマリー

クラス org.springframework.integration.kafka.channel.AbstractKafkaChannel から継承されたメソッド

クラス org.springframework.integration.channel.AbstractMessageChannel から継承されたメソッド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド

クラス java.lang.ObjectSE から継承されたメソッド

インターフェース org.springframework.messaging.MessageChannel から継承されたメソッド

インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド

インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド

コンストラクターの詳細

SubscribableKafkaChannel

メソッドの詳細

getPhase

setPhase

isRunning

setAutoStartup

isAutoStartup

onInit

createDispatcher

start

stop

stop

subscribe

unsubscribe