org.springframework.integration.kafka.channel.PollableKafkaChannel

実装されたすべてのインターフェース:: Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、ExecutorChannelInterceptorAware、ExpressionCapable、IntegrationPattern、NamedComponent、IntegrationManagement、TrackableComponent、MessageChannel、PollableChannel、InterceptableChannel

public class PollableKafkaChannel extends AbstractKafkaChannel implements PollableChannel, ExecutorChannelInterceptorAware

Apache Kafka トピックによってサポートされるポーリング可能なチャネル。

導入:: 5.4
作成者:: Gary Russell, Artem Bilan

ネストされたクラスのサマリー
クラス 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)
提供されたパラメーターを使用してインスタンスを構築します。
メソッドのサマリー
修飾子と型
メソッド
説明
void
addInterceptor(int index, ChannelInterceptor interceptor)
リストの指定されたインデックスにチャネルインターセプターを追加します。
void
addInterceptor(ChannelInterceptor interceptor)
リストの最後にチャネルインターセプターを追加します。
protected Message<?>
doReceive()
boolean
hasExecutorInterceptors()
Message<?>
receive()
Message<?>
receive(long timeout)
ChannelInterceptor
removeInterceptor(int index)
boolean
removeInterceptor(ChannelInterceptor interceptor)
void
setInterceptors(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, isLoggingEnabled, isObserved, onInit, registerMetricsCaptor, registerObservationRegistry, send, send, setDatatypes, 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.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 - 受信のソース。
メソッドの詳細
- receive
  @Nullable public Message<?> receive()
  次で指定:
  インターフェース PollableChannel の receive
- receive
  @Nullable public Message<?> receive(long timeout)
  次で指定:
  インターフェース PollableChannel の receive
- doReceive
  @Nullable protected Message<?> doReceive()
- setInterceptors
  public void setInterceptors(ListSE<ChannelInterceptor> interceptors)
  クラスからコピーされた説明: AbstractMessageChannel
  チャネルインターセプターのリストを設定します。これにより、既存のインターセプターがすべてクリアされます。
  次で指定:
  インターフェース InterceptableChannel の setInterceptors
  オーバーライド:
  クラス AbstractMessageChannel の setInterceptors
  パラメーター:
  interceptors - インターセプターのリスト。
- addInterceptor
  public void addInterceptor(ChannelInterceptor interceptor)
  クラスからコピーされた説明: AbstractMessageChannel
  リストの最後にチャネルインターセプターを追加します。
  次で指定:
  インターフェース InterceptableChannel の addInterceptor
  オーバーライド:
  クラス AbstractMessageChannel の addInterceptor
  パラメーター:
  interceptor - インターセプター。
- addInterceptor
  public void addInterceptor(int index, ChannelInterceptor interceptor)
  クラスからコピーされた説明: AbstractMessageChannel
  リストの指定されたインデックスにチャネルインターセプターを追加します。
  次で指定:
  インターフェース InterceptableChannel の addInterceptor
  オーバーライド:
  クラス AbstractMessageChannel の addInterceptor
  パラメーター:
  index - インターセプターを追加するためのインデックス。
  interceptor - インターセプター。
- removeInterceptor
  public boolean removeInterceptor(ChannelInterceptor interceptor)
  次で指定:
  インターフェース InterceptableChannel の removeInterceptor
  オーバーライド:
  クラス AbstractMessageChannel の removeInterceptor
- removeInterceptor
  @Nullable public ChannelInterceptor removeInterceptor(int index)
  次で指定:
  インターフェース InterceptableChannel の removeInterceptor
  オーバーライド:
  クラス AbstractMessageChannel の removeInterceptor
- hasExecutorInterceptors
  public boolean hasExecutorInterceptors()
  次で指定:
  インターフェース ExecutorChannelInterceptorAware の hasExecutorInterceptors

クラス PollableKafkaChannel

ネストされたクラスのサマリー

クラス 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.integration.support.management.IntegrationManagement から継承されたフィールド

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

コンストラクターのサマリー

メソッドのサマリー

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

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

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

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

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

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

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

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

コンストラクターの詳細

PollableKafkaChannel

メソッドの詳細

receive

receive

doReceive

setInterceptors

addInterceptor

addInterceptor

removeInterceptor

removeInterceptor

hasExecutorInterceptors