PublishSubscribeKafkaChannel (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
      - org.springframework.integration.kafka.channel.PublishSubscribeKafkaChannel

実装されているすべてのインターフェース:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle, BroadcastCapableChannel, ExpressionCapable, IntegrationPattern, NamedComponent, IntegrationManagement, ManageableLifecycle, ManageableSmartLifecycle, TrackableComponent, MessageChannel, SubscribableChannel, InterceptableChannel
```
public class PublishSubscribeKafkaChannel
extends SubscribableKafkaChannel
implements BroadcastCapableChannel
```
Kafka トピックによるパブリッシュ / サブスクライブチャネル。
導入:
5.4
作成者:
Gary Russell

ネストされたクラスの要約
- クラス 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

コンストラクターの概要

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

メソッドのサマリー
すべてのメソッドインスタンスメソッド具象メソッド
修飾子と型メソッドと説明
protected MessageDispatcher createDispatcher()
- クラス org.springframework.integration.kafka.channel.SubscribableKafkaChannel から継承されたメソッド
  getPhase, isAutoStartup, isRunning, onInit, setAutoStartup, setPhase, start, stop, stop, subscribe, unsubscribe
- クラス 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.integration.channel.BroadcastCapableChannel から継承されたメソッド
  isBroadcast
- インターフェース org.springframework.messaging.SubscribableChannel から継承されたメソッド
  subscribe, unsubscribe
- インターフェース 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

すべてのメソッドインスタンスメソッド具象メソッド
修飾子と型	メソッドと説明
`protected MessageDispatcher`	`createDispatcher()`

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

クラス PublishSubscribeKafkaChannel

ネストされたクラスの要約

クラス 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.SubscribableKafkaChannel から継承されたメソッド

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

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

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

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

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

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

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

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

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

コンストラクターの詳細

PublishSubscribeKafkaChannel

メソッドの詳細

createDispatcher