クラス KafkaListenerAnnotationBeanPostProcessor<K,V>

メソッドの詳細

• getOrder

  public int getOrder()

  次で指定:

  インターフェース Ordered の getOrder 

• setEndpointRegistry

  public void setEndpointRegistry(KafkaListenerEndpointRegistry endpointRegistry)

  作成したエンドポイントを保持し、関連するリスナーコンテナーのライフサイクルを管理する KafkaListenerEndpointRegistry を設定します。

  パラメーター:

  endpointRegistry - 設定する KafkaListenerEndpointRegistry

• setDefaultContainerFactoryBeanName

  public void setDefaultContainerFactoryBeanName(StringSE containerFactoryBeanName)

  デフォルトで使用する KafkaListenerContainerFactory の名前を設定します。

  何も指定されていない場合、"kafkaListenerContainerFactory" が定義されていると見なされます。

  パラメーター:

  containerFactoryBeanName - KafkaListenerContainerFactory Bean 名。

• setMessageHandlerMethodFactory

  public void setMessageHandlerMethodFactory(MessageHandlerMethodFactory messageHandlerMethodFactory)

  MessageHandlerMethodFactory を使用して、このプロセッサーによって検出されたエンドポイントを処理するメッセージリスナーを構成するように設定します。

  デフォルトでは DefaultMessageHandlerMethodFactory が使用され、追加のメソッド引数をサポートするように、または変換と検証のサポートをカスタマイズするようにさらに構成できます。詳細については、DefaultMessageHandlerMethodFactory Javadoc を参照してください。

  パラメーター:

  messageHandlerMethodFactory - MessageHandlerMethodFactory インスタンス。

• getMessageHandlerMethodFactory

  public MessageHandlerMethodFactory getMessageHandlerMethodFactory()

  設定されたハンドラーファクトリを返します。

  戻り値:

  ファクトリ。

  導入:

  2.5.7

• getEndpointRegistrar

  public KafkaListenerEndpointRegistrar getEndpointRegistrar()

  KafkaListenerEndpointRegistrar を返します。

  戻り値:

  レジストラ。

  導入:

  2.9.3

• setApplicationContext

  public void setApplicationContext(ApplicationContext applicationContext) throws BeansException

  次で指定:

  インターフェース ApplicationContextAware の setApplicationContext 

  例外:

  BeansException

• setBeanFactory

  public void setBeanFactory(BeanFactory beanFactory)

  BeanFactory を使用可能にするかどうかはオプションです。設定されていない場合、KafkaListenerConfigurer Bean は自動検出されず、endpoint registry を明示的に構成する必要があります。

  パラメーター:

  beanFactory - 使用する BeanFactory。

• setCharset

  public void setCharset(CharsetSE charset)

  メソッド引数およびその他の String/byte[] 変換で byte[] を String に変換するときに使用する文字セットを設定します。デフォルトの UTF-8。

  パラメーター:

  charset - 文字セット。

  導入:

  2.2

• afterPropertiesSet

  public void afterPropertiesSet() throws ExceptionSE

  次で指定:

  インターフェース InitializingBean の afterPropertiesSet 

  例外:

  ExceptionSE

• afterSingletonsInstantiated

  public void afterSingletonsInstantiated()

  次で指定:

  インターフェース SmartInitializingSingleton の afterSingletonsInstantiated 

• postProcessBeforeInitialization

  public ObjectSE postProcessBeforeInitialization(ObjectSE bean, StringSE beanName) throws BeansException

  次で指定:

  インターフェース BeanPostProcessor の postProcessBeforeInitialization 

  例外:

  BeansException

• postProcessAfterInitialization

  public ObjectSE postProcessAfterInitialization(ObjectSE bean, StringSE beanName) throws BeansException

  次で指定:

  インターフェース BeanPostProcessor の postProcessAfterInitialization 

  例外:

  BeansException

• processKafkaListener

  protected void processKafkaListener(KafkaListener kafkaListener, MethodSE method, ObjectSE bean, StringSE beanName)

• processListener

  protected void processListener(MethodKafkaListenerEndpoint<?,?> endpoint, KafkaListener kafkaListener, ObjectSE bean, StringSE beanName, StringSE[] topics, TopicPartitionOffset[] tps)

• assertBeanFactory

  protected void assertBeanFactory()

• noBeanFoundMessage

  protected StringSE noBeanFoundMessage(ObjectSE target, StringSE listenerBeanName, StringSE requestedBeanName, ClassSE<?> expectedClass)