クラス PollableKafkaChannel
java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.channel.AbstractMessageChannel
org.springframework.integration.kafka.channel.AbstractKafkaChannel
org.springframework.integration.kafka.channel.PollableKafkaChannel
- 実装されているすべてのインターフェース:
Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、ExecutorChannelInterceptorAware、ComponentSourceAware、ExpressionCapable、IntegrationPattern、NamedComponent、IntegrationManagement、TrackableComponent、MessageChannel、PollableChannel、InterceptableChannel
public class PollableKafkaChannel
extends AbstractKafkaChannel
implements PollableChannel, ExecutorChannelInterceptorAware
Apache Kafka トピックによってサポートされるポーリング可能なチャネル。
- 導入:
- 5.4
- 作成者:
- Gary Russell, Artem Bilan, Ngoc Nhan
ネストされたクラスのサマリー
クラス 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コンストラクターの概要
コンストラクターコンストラクター説明PollableKafkaChannel(org.springframework.kafka.core.KafkaOperations<?, ?> template, KafkaMessageSource<?, ?> source) 提供されたパラメーターを使用してインスタンスを構築します。メソッドのサマリー
修飾子と型メソッド説明voidaddInterceptor(int index, ChannelInterceptor interceptor) リストの指定されたインデックスにチャネルインターセプターを追加します。voidaddInterceptor(ChannelInterceptor interceptor) リストの最後にチャネルインターセプターを追加します。protected Message<?> booleanprotected voidonInit()サブクラスは、初期化ロジック用にこれを実装できます。Message<?> receive()Message<?> receive(long timeout) removeInterceptor(int index) booleanremoveInterceptor(ChannelInterceptor interceptor) voidsetInterceptors(ListSE<ChannelInterceptor> interceptors) チャネルインターセプターのリストを設定します。クラス org.springframework.integration.kafka.channel.AbstractKafkaChannel から継承されたメソッド
doSend, getGroupId, setGroupIdクラス org.springframework.integration.channel.AbstractMessageChannel から継承されたメソッド
destroy, getComponentType, getFullChannelName, getIChannelInterceptorList, getIntegrationPatternType, getInterceptors, getMetricsCaptor, getOverrides, isApplicationRunning, isLoggingEnabled, isObserved, registerMetricsCaptor, registerObservationRegistry, send, send, setDatatypes, setLoggingEnabled, setMessageConverter, setObservationConvention, setShouldTrackクラス org.springframework.integration.context.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クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, wait, waitSE, waitSEインターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたメソッド
getManagedName, getManagedType, getThisAs, setManagedName, setManagedTypeインターフェース org.springframework.messaging.support.InterceptableChannel から継承されたメソッド
getInterceptorsインターフェース org.springframework.messaging.MessageChannel から継承されたメソッド
send, sendインターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド
getBeanName, getComponentName
コンストラクターの詳細
PollableKafkaChannel
public PollableKafkaChannel(org.springframework.kafka.core.KafkaOperations<?, ?> template, KafkaMessageSource<?, ?> source) 提供されたパラメーターを使用してインスタンスを構築します。- パラメーター:
template- 送信用のテンプレート。source- 受信のソース。
メソッドの詳細
onInit
protected void onInit()クラスからコピーされた説明:IntegrationObjectSupportサブクラスは、初期化ロジック用にこれを実装できます。- オーバーライド:
- クラス
AbstractMessageChannelのonInit
receive
- 次で指定:
- インターフェース
PollableChannelのreceive
receive
- 次で指定:
- インターフェース
PollableChannelのreceive
doReceive
setInterceptors
クラスからコピーされた説明:AbstractMessageChannelチャネルインターセプターのリストを設定します。これにより、既存のインターセプターがすべてクリアされます。- 次で指定:
- インターフェース
InterceptableChannelのsetInterceptors - オーバーライド:
- クラス
AbstractMessageChannelのsetInterceptors - パラメーター:
interceptors- インターセプターのリスト。
addInterceptor
クラスからコピーされた説明:AbstractMessageChannelリストの最後にチャネルインターセプターを追加します。- 次で指定:
- インターフェース
InterceptableChannelのaddInterceptor - オーバーライド:
- クラス
AbstractMessageChannelのaddInterceptor - パラメーター:
interceptor- インターセプター。
addInterceptor
クラスからコピーされた説明:AbstractMessageChannelリストの指定されたインデックスにチャネルインターセプターを追加します。- 次で指定:
- インターフェース
InterceptableChannelのaddInterceptor - オーバーライド:
- クラス
AbstractMessageChannelのaddInterceptor - パラメーター:
index- インターセプターを追加するためのインデックス。interceptor- インターセプター。
removeInterceptor
- 次で指定:
- インターフェース
InterceptableChannelのremoveInterceptor - オーバーライド:
- クラス
AbstractMessageChannelのremoveInterceptor
removeInterceptor
- 次で指定:
- インターフェース
InterceptableChannelのremoveInterceptor - オーバーライド:
- クラス
AbstractMessageChannelのremoveInterceptor
hasExecutorInterceptors
public boolean hasExecutorInterceptors()- 次で指定:
- インターフェース
ExecutorChannelInterceptorAwareのhasExecutorInterceptors