クラス 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、ExpressionCapable、IntegrationPattern、NamedComponent、IntegrationManagement、ManageableLifecycle、ManageableSmartLifecycle、TrackableComponent、MessageChannel、SubscribableChannel、InterceptableChannel
public class PublishSubscribeKafkaChannel
extends SubscribableKafkaChannel
implements BroadcastCapableChannel
Apache 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.integration.support.management.IntegrationManagement から継承されたフィールド
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAMEインターフェース org.springframework.messaging.MessageChannel から継承されたフィールド
INDEFINITE_TIMEOUTコンストラクターのサマリー
コンストラクターコンストラクター説明PublishSubscribeKafkaChannel(org.springframework.kafka.core.KafkaOperations<?, ?> template, org.springframework.kafka.config.KafkaListenerContainerFactory<?> factory, StringSE channelTopic) 提供されたパラメーターを使用してインスタンスを構築します。メソッドのサマリー
クラス org.springframework.integration.kafka.channel.SubscribableKafkaChannel から継承されたメソッド
getPhase, isAutoStartup, isRunning, onInit, setAutoStartup, setMessageConverter, 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, isObserved, registerMetricsCaptor, registerObservationRegistry, removeInterceptor, removeInterceptor, send, send, setDatatypes, setInterceptors, setLoggingEnabled, setMessageConverter, setObservationConvention, setShouldTrackクラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringクラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, wait, waitSE, waitSEインターフェース org.springframework.integration.channel.BroadcastCapableChannel から継承されたメソッド
isBroadcastインターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド
getManagedName, getManagedType, getThisAs, setManagedName, setManagedTypeインターフェース org.springframework.messaging.MessageChannel から継承されたメソッド
send, sendインターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド
getBeanName, getComponentNameインターフェース org.springframework.messaging.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