フィールドの詳細

• logger

  protected Log logger

コンストラクターの詳細

• StreamListenerContainer

  public StreamListenerContainer​(com.rabbitmq.stream.Environment environment)

  提供された環境を使用してインスタンスを構築します。

  パラメーター:

  environment - 環境。

• StreamListenerContainer

  public StreamListenerContainer​(com.rabbitmq.stream.Environment environment,
                                 @Nullable
                                 com.rabbitmq.stream.Codec codec)

  提供された環境とコーデックを使用してインスタンスを構築します。

  パラメーター:

  environment - 環境。

  codec - 返信メッセージの作成に使用されるコーデック。

メソッドの詳細

• setQueueNames

  public void setQueueNames​(StringSE... queueNames)

  インターフェースからコピーされた説明: MessageListenerContainer
  キュー名を設定します。

  次で指定:

  インターフェース MessageListenerContainer の setQueueNames 

  パラメーター:

  queueNames - キュー名。

• getStreamConverter

  public StreamMessageConverter getStreamConverter()

  Message を Message に変換するために使用される StreamMessageConverter を取得します。

  戻り値:

  コンバーター。

• setStreamConverter

  public void setStreamConverter​(StreamMessageConverter messageConverter)

  Message を Message に変換するために使用される StreamMessageConverter を設定します。

  パラメーター:

  messageConverter - コンバーター。

• setConsumerCustomizer

  public void setConsumerCustomizer​(ConsumerCustomizer consumerCustomizer)

  コンシューマービルダーをビルドする前にカスタマイズします。

  パラメーター:

  consumerCustomizer - カスタマイザー。

• getListenerId

  @Nullable
  public StringSE getListenerId()

  リスナーの 'id' 属性。

  戻り値:

  ID (ID が設定されていない場合はコンテナー Bean 名)。

• setListenerId

  public void setListenerId​(StringSE listenerId)

  インターフェースからコピーされた説明: MessageListenerContainer
  リスナー ID を設定します。

  次で指定:

  インターフェース MessageListenerContainer の setListenerId 

  パラメーター:

  listenerId - ID。

• getBeanName

  @Nullable
  public StringSE getBeanName()

  Bean 名を返します。

  戻り値:

  Bean 名。

• setBeanName

  public void setBeanName​(StringSE beanName)

  次で指定:

  インターフェース BeanNameAware の setBeanName 

• setAutoStartup

  public void setAutoStartup​(boolean autoStart)

  インターフェースからコピーされた説明: MessageListenerContainer
  自動起動を設定します。

  次で指定:

  インターフェース MessageListenerContainer の setAutoStartup 

  パラメーター:

  autoStart - 自動開始に真。

• isAutoStartup

  public boolean isAutoStartup()

  次で指定:

  インターフェース SmartLifecycle の isAutoStartup 

• getMessageListener

  @Nullable
  public ObjectSE getMessageListener()

  インターフェースからコピーされた説明: MessageListenerContainer
  メッセージリスナーを取得します。

  次で指定:

  インターフェース MessageListenerContainer の getMessageListener 

  戻り値:

  メッセージリスナーオブジェクト。

• isRunning

  public boolean isRunning()

  次で指定:

  インターフェース Lifecycle の isRunning 

• start

  public void start()

  次で指定:

  インターフェース Lifecycle の start 

• stop

  public void stop()

  次で指定:

  インターフェース Lifecycle の stop 

• setupMessageListener

  public void setupMessageListener​(MessageListener messageListener)

  インターフェースからコピーされた説明: MessageListenerContainer
  使用するメッセージリスナーを設定します。そのメッセージリスナ型がサポートされていない場合、IllegalArgumentExceptionSE をスローします。

  次で指定:

  インターフェース MessageListenerContainer の setupMessageListener 

  パラメーター:

  messageListener - object を MessageListener にラップします。