クラス 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
ネストされたクラスの概要
クラス 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コンストラクター概要
コンストラクターコンストラクター説明PollableKafkaChannel(org.springframework.kafka.core.KafkaOperations<?, ?> template, KafkaMessageSource<?, ?> source) 提供されたパラメーターを使用してインスタンスを構築します。方法の概要
修飾子と型メソッド説明voidaddInterceptor(int index, ChannelInterceptor interceptor) リストの指定されたインデックスにチャネルインターセプターを追加します。voidaddInterceptor(ChannelInterceptor interceptor) リストの最後にチャネルインターセプターを追加します。protected @Nullable Message<?> booleanprotected voidonInit()サブクラスは、初期化ロジック用にこれを実装できます。@Nullable Message<?> receive()@Nullable Message<?> receive(long timeout) removeInterceptor(int index) booleanremoveInterceptor(ChannelInterceptor interceptor) voidsetInterceptors(ListSE<ChannelInterceptor> interceptors) チャネルインターセプターのリストを設定します。クラス AbstractKafkaChannel から継承されたメソッド
doSend, getGroupId, setGroupIdクラス AbstractMessageChannel から継承されたメソッド
destroy, getComponentType, getFullChannelName, getIChannelInterceptorList, getIntegrationPatternType, getInterceptors, getMetricsCaptor, getOverrides, isApplicationRunning, isLoggingEnabled, isObserved, registerMetricsCaptor, registerObservationRegistry, send, send, setDatatypes, 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インターフェース IntegrationManagement から継承されたメソッド
getManagedName, getManagedType, getThisAs, setManagedName, setManagedTypeインターフェース InterceptableChannel から継承されたメソッド
getInterceptorsインターフェース MessageChannel から継承されたメソッド
send, sendインターフェース 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