コンストラクターの詳細

• AbstractRabbitListenerEndpoint

  public AbstractRabbitListenerEndpoint()

メソッドの詳細

• setBeanFactory

  public void setBeanFactory​(BeanFactory beanFactory)
                      throws BeansException

  次で指定:

  インターフェース BeanFactoryAware の setBeanFactory 

  例外:

  BeansException

• getBeanFactory

  @Nullable
  protected BeanFactory getBeanFactory()

• getResolver

  protected BeanExpressionResolver getResolver()

• getBeanResolver

  protected BeanResolver getBeanResolver()

• getBeanExpressionContext

  protected BeanExpressionContext getBeanExpressionContext()

• setId

  public void setId​(StringSE id)

• getId

  public StringSE getId()

  次で指定:

  インターフェース RabbitListenerEndpoint の getId 

  戻り値:

  このエンドポイントの ID。エンドポイントが実際のリスナーコンテナーに対して解決されるときに、ID をさらに修飾できます。

  関連事項:

  RabbitListenerContainerFactory.createListenerContainer(org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint)

• setQueues

  public void setQueues​(Queue... queues)

  使用するキューを設定します。Queue インスタンスまたはキュー名のいずれかを指定する必要がありますが、両方を指定することはできません。

  パラメーター:

  queues - 設定します。

  関連事項:

  setQueueNames(java.lang.String...)

• getQueues

  public CollectionSE<Queue> getQueues()

  戻り値:

  このエンドポイントのキュー。

• getQueueNames

  public CollectionSE<StringSE> getQueueNames()

  戻り値:

  このエンドポイントのキュー名。

• setQueueNames

  public void setQueueNames​(StringSE... queueNames)

  使用するキュー名を設定します。Queue インスタンスまたはキュー名のいずれかを指定する必要がありますが、両方を指定することはできません。

  パラメーター:

  queueNames - 設定します。

  関連事項:

  setQueues(org.springframework.amqp.core.Queue...)

• setExclusive

  public void setExclusive​(boolean exclusive)

  コンテナー内の単一のコンシューマーがキューを排他的に使用し、他のコンシューマーがキューからメッセージを受信できないようにする場合に設定します。

  パラメーター:

  exclusive - 排他的な boolean フラグ。

• isExclusive

  public boolean isExclusive()

  戻り値:

  排他的 boolean フラグ。

• setPriority

  public void setPriority​(IntegerSE priority)

  このエンドポイントの優先度を設定します。

  パラメーター:

  priority - プライオリティ値。

• getPriority

  public IntegerSE getPriority()

  戻り値:

  このエンドポイントの優先度、または優先度が設定されていない場合は null。

• setConcurrency

  public void setConcurrency​(StringSE concurrency)

  このエンドポイントの同時実行を設定します。通常、コンテナーファクトリの同時実行設定をオーバーライドします。内容はコンテナーの実装に依存します。

  パラメーター:

  concurrency - 並行性。

  導入:

  2.0

• getConcurrency

  public StringSE getConcurrency()

  このエンドポイントの同時実行性。この抽象クラスでは使用されません。コンテナーの種類に適した並行性を設定するためにサブクラスによって使用されます。

  次で指定:

  インターフェース RabbitListenerEndpoint の getConcurrency 

  戻り値:

  並行性。

  導入:

  2.0

• setAdmin

  public void setAdmin​(AmqpAdmin admin)

  使用する AmqpAdmin インスタンスを設定します。

  パラメーター:

  admin - AmqpAdmin インスタンス。

• getAdmin

  public AmqpAdmin getAdmin()

  戻り値:

  使用する AmqpAdmin インスタンス、または何も構成されていない場合は null。

• getGroup

  public StringSE getGroup()

  次で指定:

  インターフェース RabbitListenerEndpoint の getGroup 

  戻り値:

  このエンドポイントのグループ、またはグループにない場合は null。

• setGroup

  public void setGroup​(StringSE group)

  対応するリスナーコンテナーのグループを設定します。

  パラメーター:

  group - グループ。

  導入:

  1.5

• setAutoStartup

  public void setAutoStartup​(BooleanSE autoStartup)

  デフォルトの autoStartup プロパティをオーバーライドします。

  パラメーター:

  autoStartup - autoStartup。

  導入:

  2.0

• getAutoStartup

  public BooleanSE getAutoStartup()

  インターフェースからコピーされた説明: RabbitListenerEndpoint
  デフォルトの autoStartup プロパティをオーバーライドします。

  次で指定:

  インターフェース RabbitListenerEndpoint の getAutoStartup 

  戻り値:

  autoStartup。

• getMessageConverter

  public MessageConverter getMessageConverter()

  インターフェースからコピーされた説明: RabbitListenerEndpoint
  このエンドポイントが、コンテナーファクトリがメッセージコンバーターをエンドポイントのアダプターに渡すための推奨される方法をサポートしているかどうかを確認するために、コンテナーファクトリによって使用されます。null が返された場合、ファクトリはコンテナー経由でコンバーターを渡す従来の方法にフォールバックします。

  次で指定:

  インターフェース RabbitListenerEndpoint の getMessageConverter 

  戻り値:

  コンバーター。

• setMessageConverter

  public void setMessageConverter​(MessageConverter messageConverter)

  インターフェースからコピーされた説明: RabbitListenerEndpoint
  コンテナーファクトリがメッセージコンバーターをエンドポイントのアダプターに渡すための推奨される方法。

  次で指定:

  インターフェース RabbitListenerEndpoint の setMessageConverter 

  パラメーター:

  messageConverter - コンバーター。

• getTaskExecutor

  public TaskExecutor getTaskExecutor()

  インターフェースからコピーされた説明: RabbitListenerEndpoint
  このエンドポイントのリスナーコンテナーに使用するタスクエグゼキュータを取得します。コンテナーファクトリに設定されたエグゼキュータをオーバーライドします。

  次で指定:

  インターフェース RabbitListenerEndpoint の getTaskExecutor 

  戻り値:

  執行者。

• setTaskExecutor

  public void setTaskExecutor​(TaskExecutor taskExecutor)

  デフォルトのタスクエグゼキューターをオーバーライドします。

  パラメーター:

  taskExecutor - 執行者。

  導入:

  2.2

• isBatchListener

  public boolean isBatchListener()

• setBatchListener

  public void setBatchListener​(boolean batchListener)

  このエンドポイントがバッチリスナーを作成する必要がある場合は、true に設定します。

  次で指定:

  インターフェース RabbitListenerEndpoint の setBatchListener 

  パラメーター:

  batchListener - バッチリスナーの場合は true。

  導入:

  2.2

  関連事項:

  setBatchingStrategy(BatchingStrategy)

• getBatchingStrategy

  @Nullable
  public BatchingStrategy getBatchingStrategy()

• setBatchingStrategy

  public void setBatchingStrategy​(BatchingStrategy batchingStrategy)

  インターフェースからコピーされた説明: RabbitListenerEndpoint
  メッセージのデバッチ時に使用する BatchingStrategy を設定します。

  次で指定:

  インターフェース RabbitListenerEndpoint の setBatchingStrategy 

  パラメーター:

  batchingStrategy - バッチ戦略。

  関連事項:

  RabbitListenerEndpoint.setBatchListener(boolean)

• getAckMode

  @Nullable
  public AcknowledgeMode getAckMode()

  インターフェースからコピーされた説明: RabbitListenerEndpoint
  コンテナーファクトリの AcknowledgeMode をオーバーライドします。

  次で指定:

  インターフェース RabbitListenerEndpoint の getAckMode 

  戻り値:

  承認モード。

• setAckMode

  public void setAckMode​(AcknowledgeMode mode)

• getReplyPostProcessor

  public ReplyPostProcessor getReplyPostProcessor()

  インターフェースからコピーされた説明: RabbitListenerEndpoint
  ReplyPostProcessor を返して、返信メッセージを送信する前に後処理します。

  次で指定:

  インターフェース RabbitListenerEndpoint の getReplyPostProcessor 

  戻り値:

  ポストプロセッサー。

• setReplyPostProcessor

  public void setReplyPostProcessor​(ReplyPostProcessor replyPostProcessor)

  ReplyPostProcessor を設定して、レスポンスメッセージを送信する前に後処理します。

  パラメーター:

  replyPostProcessor - ポストプロセッサー。

  導入:

  2.2.5

• getReplyContentType

  public StringSE getReplyContentType()

  インターフェースからコピーされた説明: RabbitListenerEndpoint
  返信コンテンツ型を取得します。

  次で指定:

  インターフェース RabbitListenerEndpoint の getReplyContentType 

  戻り値:

  コンテンツ型。

• setReplyContentType

  public void setReplyContentType​(StringSE replyContentType)

  返信内容の種類を設定します。

  パラメーター:

  replyContentType - コンテンツ型。

  導入:

  2.3

• isConverterWinsContentType

  public boolean isConverterWinsContentType()

  インターフェースからコピーされた説明: RabbitListenerEndpoint
  コンバーターによって設定されたコンテンツ型が優先されるかどうかを返します。

  次で指定:

  インターフェース RabbitListenerEndpoint の isConverterWinsContentType 

  戻り値:

  返信コンテンツ型を常に適用する場合は false。

• setConverterWinsContentType

  public void setConverterWinsContentType​(boolean converterWinsContentType)

  コンバーターで設定したコンテンツ型を優先するかどうかを設定します。

  パラメーター:

  converterWinsContentType - 返信コンテンツ型を常に適用する場合は false。

  導入:

  2.3

• setupListenerContainer

  public void setupListenerContainer​(MessageListenerContainer listenerContainer)

  インターフェースからコピーされた説明: RabbitListenerEndpoint
  このエンドポイントで定義されたモデルを使用して、指定されたメッセージリスナーコンテナーをセットアップします。

  このエンドポイントは、それを使用可能にするために、指定されたコンテナーのリクエストされた欠落オプションを提供する必要があります。通常、これは使用する queues および messageListener の設定に関するものですが、実装はすでに設定されているデフォルト設定をオーバーライドする場合があります。

  次で指定:

  インターフェース RabbitListenerEndpoint の setupListenerContainer 

  パラメーター:

  listenerContainer - 設定するリスナーコンテナー

• createMessageListener

  protected abstract MessageListener createMessageListener​(MessageListenerContainer container)

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

  パラメーター:

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

  戻り値:

  MessageListener インスタンス。

• getEndpointDescription

  protected StringBuilderSE getEndpointDescription()

  戻り値:

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

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

• toString

  public StringSE toString()

  オーバーライド:

  クラス ObjectSE の toString