クラス PublishSubscribeKafkaChannel
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, ComponentSourceAware, ExpressionCapable, IntegrationPattern, NamedComponent, IntegrationManagement, ManageableLifecycle, ManageableSmartLifecycle, TrackableComponent, MessageChannel, SubscribableChannel, InterceptableChannel
public class PublishSubscribeKafkaChannel
extends SubscribableKafkaChannel
implements BroadcastCapableChannel
Apache Kafka トピックによってサポートされるパブリッシュ / サブスクライブチャネル。
- 導入:
- 5.4
- 作成者:
- Gary Russell
ネストされたクラスの概要
クラス AbstractMessageChannel から継承されたネストクラス / インターフェース
AbstractMessageChannel.ChannelInterceptorListインターフェース IntegrationManagement から継承されたネストクラス / インターフェース
IntegrationManagement.ManagementOverridesフィールド概要
クラス AbstractKafkaChannel から継承されたフィールド
topicクラス AbstractMessageChannel から継承されたフィールド
interceptors, metersクラス IntegrationObjectSupport から継承されたフィールド
EXPRESSION_PARSER, loggerインターフェース IntegrationManagement から継承されたフィールド
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAMEインターフェース MessageChannel から継承されたフィールド
INDEFINITE_TIMEOUTコンストラクター概要
コンストラクターコンストラクター説明PublishSubscribeKafkaChannel(org.springframework.kafka.core.KafkaOperations<?, ?> template, org.springframework.kafka.config.KafkaListenerContainerFactory<?> factory, StringSE channelTopic) 提供されたパラメーターを使用してインスタンスを構築します。方法の概要
クラス SubscribableKafkaChannel から継承されたメソッド
getPhase, isAutoStartup, isRunning, onInit, setAutoStartup, setMessageConverter, setPhase, start, stop, stop, subscribe, unsubscribeクラス AbstractKafkaChannel から継承されたメソッド
doSend, getGroupId, setGroupIdクラス AbstractMessageChannel から継承されたメソッド
addInterceptor, addInterceptor, destroy, getComponentType, getFullChannelName, getIChannelInterceptorList, getIntegrationPatternType, getInterceptors, getMetricsCaptor, getOverrides, isApplicationRunning, isLoggingEnabled, isObserved, registerMetricsCaptor, registerObservationRegistry, removeInterceptor, removeInterceptor, send, send, setDatatypes, setInterceptors, setLoggingEnabled, setMessageConverter, setObservationConvention, setShouldTrackクラス IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentDescription, getComponentName, getComponentSource, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentDescription, setComponentName, setComponentSource, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringクラス ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, wait, waitSE, waitSEインターフェース BroadcastCapableChannel から継承されたメソッド
isBroadcastインターフェース IntegrationManagement から継承されたメソッド
getManagedName, getManagedType, getThisAs, setManagedName, setManagedTypeインターフェース MessageChannel から継承されたメソッド
send, sendインターフェース NamedComponent から継承されたメソッド
getBeanName, getComponentNameインターフェース SmartLifecycle から継承されたメソッド
isPauseableインターフェース SubscribableChannel から継承されたメソッド
subscribe, unsubscribe
コンストラクターの詳細
PublishSubscribeKafkaChannel
public PublishSubscribeKafkaChannel(org.springframework.kafka.core.KafkaOperations<?, ?> template, org.springframework.kafka.config.KafkaListenerContainerFactory<?> factory, StringSE channelTopic) 提供されたパラメーターを使用してインスタンスを構築します。- パラメーター:
template- 送信用のテンプレート。factory- 受け取るためのコンテナーを作成するためのファクトリ。channelTopic- トピック。
方法の詳細
createDispatcher
- オーバーライド:
- クラス
SubscribableKafkaChannelのcreateDispatcher