クラス MethodKafkaListenerEndpoint<K,V>

メソッドの詳細

• setBean

  public void setBean(ObjectSE bean)

  このエンドポイントを管理する必要があるオブジェクトインスタンスを設定します。

  パラメーター:

  bean - ターゲット Bean インスタンス。

• getBean

  public ObjectSE getBean()

• setMethod

  public void setMethod(MethodSE method)

  このエンドポイントによって管理されるメッセージを処理するために呼び出すメソッドを設定します。

  パラメーター:

  method - bean のターゲットメソッド。

• getMethod

  public MethodSE getMethod()

• setMessageHandlerMethodFactory

  public void setMessageHandlerMethodFactory(MessageHandlerMethodFactory messageHandlerMethodFactory)

  このエンドポイントの呼び出しの管理を担当する InvocableHandlerMethod を構築するために使用する MessageHandlerMethodFactory を設定します。

  パラメーター:

  messageHandlerMethodFactory - MessageHandlerMethodFactory インスタンス。

• setErrorHandler

  public void setErrorHandler(KafkaListenerErrorHandler errorHandler)

  リスナーメソッドが例外をスローした場合に呼び出すように KafkaListenerErrorHandler を設定します。

  パラメーター:

  errorHandler - エラーハンドラー。

  導入:

  1.3

• setMessagingConverter

  public void setMessagingConverter(SmartMessageConverter messagingConverter)

  spring-messaging SmartMessageConverter を設定して、レコード値を目的の型に変換します。これにより、受信にマップされるときに MessageHeaders.CONTENT_TYPE が文字列に変換されます。

  パラメーター:

  messagingConverter - コンバーター。

  導入:

  2.7.1

• getMessageHandlerMethodFactory

  protected MessageHandlerMethodFactory getMessageHandlerMethodFactory()

  MessageHandlerMethodFactory を返します。

  戻り値:

  messageHandlerMethodFactory

• createMessageListener

  protected MessagingMessageListenerAdapter<K,V> createMessageListener(MessageListenerContainer container, @Nullable MessageConverter messageConverter)

  クラスからコピーされた説明: AbstractKafkaListenerEndpoint

  指定されたコンテナーに対してこのエンドポイントを提供できる MessageListener を作成します。

  次で指定:

  クラス AbstractKafkaListenerEndpoint<K,V> の createMessageListener 

  パラメーター:

  container - MessageListenerContainer を使用して MessageListener を作成します。

  messageConverter - メッセージコンバーター - null の場合があります。

  戻り値:

  MessageListener インスタンス。

• configureListenerAdapter

  protected HandlerAdapter configureListenerAdapter(MessagingMessageListenerAdapter<K,V> messageListener)

  このリスナーアダプターの HandlerAdapter を作成します。

  パラメーター:

  messageListener - リスナーアダプター。

  戻り値:

  ハンドラーアダプター。

• createMessageListenerInstance

  protected MessagingMessageListenerAdapter<K,V> createMessageListenerInstance(@Nullable MessageConverter messageConverter)

  空の MessagingMessageListenerAdapter インスタンスを作成します。

  パラメーター:

  messageConverter - コンバーター（null の場合があります）。

  戻り値:

  MessagingMessageListenerAdapter インスタンス。

• getEndpointDescription

  protected StringBuilderSE getEndpointDescription()

  クラスからコピーされた説明: AbstractKafkaListenerEndpoint

  このエンドポイントの説明を返します。

  オーバーライド:

  クラス AbstractKafkaListenerEndpoint<K,V> の getEndpointDescription 

  戻り値:

  このエンドポイントの説明。

  toString() 結果に含めるために、サブクラスで使用できます。