クラス QueueBuilder
- java.lang.ObjectSE
-
- org.springframework.amqp.core.AbstractBuilder
-
- org.springframework.amqp.core.QueueBuilder
public final class QueueBuilder extends AbstractBuilder
流れるような API を使用して Spring AMQP キューを構築します。- 導入:
- 1.6
- 作成者:
- Maciej Walkowiak, Gary Russell
ネストされたクラスのサマリー
ネストされたクラス 修飾子と型 クラス 説明 static class
QueueBuilder.LeaderLocator
キューリーダーを見つけます。static class
QueueBuilder.MasterLocator
使用すべきではありません。static class
QueueBuilder.Overflow
オーバーフロー引数値。
メソッドのサマリー
すべてのメソッド 静的メソッド インスタンスメソッド 具象メソッド 非推奨のメソッド 修飾子と型 メソッド 説明 QueueBuilder
autoDelete()
最終キューは自動削除されます。Queue
build()
最終キューを構築します。QueueBuilder
deadLetterExchange(StringSE dlx)
期限切れまたは拒否されたメッセージをルーティングする配信不能交換を設定します。QueueBuilder
deadLetterRoutingKey(StringSE dlrk)
期限切れまたは拒否されたメッセージを配信不能交換にルーティングするときに使用するルーティングキーを設定します。QueueBuilder
deliveryLimit(int limit)
配信制限を設定します。クォーラムキューにのみ適用されます。static QueueBuilder
durable()
生成された一意の名前spring.gen-<random>
を持つ永続キューのビルダーを作成します。static QueueBuilder
durable(StringSE name)
永続キューのビルダーを作成します。QueueBuilder
exclusive()
最終キューは排他的になります。QueueBuilder
expires(int expires)
キューが削除される前に未使用のままでいられる時間を設定します。QueueBuilder
lazy()
キューを遅延モードに設定し、できるだけ多くのメッセージをディスクに保持して、ブローカーの RAM 使用量を減らします。QueueBuilder
leaderLocator(QueueBuilder.LeaderLocator locator)
ノードのクラスター上でキューマスターを配置するノードを決定するマスターロケーターモードを設定します。QueueBuilder
masterLocator(QueueBuilder.MasterLocator locator)
使用すべきではありません。QueueBuilder
maxLength(int count)
ドロップを開始する前にキューで許可される (準備完了の) メッセージの数を設定します。QueueBuilder
maxLengthBytes(int bytes)
ドロップを開始する前に、キューで許可される集約ボディの合計サイズを設定します。QueueBuilder
maxPriority(int maxPriority)
キューがサポートする優先度レベルの場合、最大数を設定します。設定されていない場合、キューはメッセージの優先度をサポートしません。static QueueBuilder
nonDurable()
非永続 (一時) キューのビルダーを作成します。static QueueBuilder
nonDurable(StringSE name)
非永続 (一時) キューのビルダーを作成します。QueueBuilder
overflow(QueueBuilder.Overflow overflow)
最大メッセージまたは最大メッセージサイズを超えたためにメッセージがドロップされた場合のオーバーフローモードを設定します。QueueBuilder
quorum()
queue 引数を設定して、型が "classic" ではなく "quorum" のキューを宣言します。QueueBuilder
singleActiveConsumer()
"x-single-active-consumer" キュー引数を設定します。QueueBuilder
stream()
queue 引数を設定して、"classic" ではなく "stream" 型のキューを宣言します。QueueBuilder
ttl(int ttl)
メッセージの有効期限を設定してから破棄するか、構成されている場合はデッドレター交換にルーティングします。QueueBuilder
withArgument(StringSE key, ObjectSE value)
最後のキューには、キューを宣言するために使用される引数が含まれます。QueueBuilder
withArguments(MapSE<StringSE,ObjectSE> arguments)
最後のキューには、キューを宣言するために使用される引数が含まれます。クラス org.springframework.amqp.core.AbstractBuilder から継承されたメソッド
getArguments, getOrCreateArguments
メソッドの詳細
durable
public static QueueBuilder durable()
生成された一意の名前spring.gen-<random>
を持つ永続キューのビルダーを作成します。- 戻り値:
- QueueBuilder インスタンス。
nonDurable
public static QueueBuilder nonDurable()
非永続 (一時) キューのビルダーを作成します。- 戻り値:
- QueueBuilder インスタンス。
durable
public static QueueBuilder durable(StringSE name)
永続キューのビルダーを作成します。- パラメーター:
name
- キューの名前。- 戻り値:
- QueueBuilder インスタンス。
nonDurable
public static QueueBuilder nonDurable(StringSE name)
非永続 (一時) キューのビルダーを作成します。- パラメーター:
name
- キューの名前。- 戻り値:
- QueueBuilder インスタンス。
exclusive
public QueueBuilder exclusive()
最終キューは排他的になります。- 戻り値:
- QueueBuilder インスタンス。
autoDelete
public QueueBuilder autoDelete()
最終キューは自動削除されます。- 戻り値:
- QueueBuilder インスタンス。
withArgument
public QueueBuilder withArgument(StringSE key, ObjectSE value)
最後のキューには、キューを宣言するために使用される引数が含まれます。- パラメーター:
key
- 引数名value
- 引数値- 戻り値:
- QueueBuilder インスタンス。
withArguments
public QueueBuilder withArguments(MapSE<StringSE,ObjectSE> arguments)
最後のキューには、キューを宣言するために使用される引数が含まれます。- パラメーター:
arguments
- 引数マップ- 戻り値:
- QueueBuilder インスタンス。
ttl
public QueueBuilder ttl(int ttl)
メッセージの有効期限を設定してから破棄するか、構成されている場合はデッドレター交換にルーティングします。- パラメーター:
ttl
- 存続時間 (ミリ秒)。- 戻り値:
- ビルダー。
- 導入:
- 2.2
- 関連事項:
deadLetterExchange(String)
expires
public QueueBuilder expires(int expires)
キューが削除される前に未使用のままでいられる時間を設定します。- パラメーター:
expires
- 有効期限 (ミリ秒)。- 戻り値:
- ビルダー。
- 導入:
- 2.2
maxLength
public QueueBuilder maxLength(int count)
ドロップを開始する前にキューで許可される (準備完了の) メッセージの数を設定します。- パラメーター:
count
- 許容される (準備完了の) メッセージの数。- 戻り値:
- ビルダー。
- 導入:
- 2.2
- 関連事項:
overflow(Overflow)
maxLengthBytes
public QueueBuilder maxLengthBytes(int bytes)
ドロップを開始する前に、キューで許可される集約ボディの合計サイズを設定します。- パラメーター:
bytes
- 総集合体サイズ。- 戻り値:
- ビルダー。
- 導入:
- 2.2
overflow
public QueueBuilder overflow(QueueBuilder.Overflow overflow)
最大メッセージまたは最大メッセージサイズを超えたためにメッセージがドロップされた場合のオーバーフローモードを設定します。- パラメーター:
overflow
-QueueBuilder.Overflow.dropHead
またはQueueBuilder.Overflow.rejectPublish
。- 戻り値:
- ビルダー。
- 導入:
- 2.2
deadLetterExchange
public QueueBuilder deadLetterExchange(StringSE dlx)
期限切れまたは拒否されたメッセージをルーティングする配信不能交換を設定します。- パラメーター:
dlx
- デッドレター交換。- 戻り値:
- ビルダー。
- 導入:
- 2.2
- 関連事項:
deadLetterRoutingKey(String)
deadLetterRoutingKey
public QueueBuilder deadLetterRoutingKey(StringSE dlrk)
期限切れまたは拒否されたメッセージを配信不能交換にルーティングするときに使用するルーティングキーを設定します。- パラメーター:
dlrk
- 配信不能ルーティングキー。- 戻り値:
- ビルダー。
- 導入:
- 2.2
- 関連事項:
deadLetterExchange(String)
maxPriority
public QueueBuilder maxPriority(int maxPriority)
キューがサポートする優先度レベルの場合、最大数を設定します。設定されていない場合、キューはメッセージの優先度をサポートしません。- パラメーター:
maxPriority
- 最大の優先度。- 戻り値:
- ビルダー。
- 導入:
- 2.2
lazy
public QueueBuilder lazy()
キューを遅延モードに設定し、できるだけ多くのメッセージをディスクに保持して、ブローカーの RAM 使用量を減らします。設定されていない場合、キューはメッセージをできるだけ速く配信するためにメモリ内キャッシュを保持します。- 戻り値:
- ビルダー。
- 導入:
- 2.2
masterLocator
@DeprecatedSE public QueueBuilder masterLocator(QueueBuilder.MasterLocator locator)
使用すべきではありません。ノードのクラスター上でキューマスターを配置するノードを決定するマスターロケーターモードを設定します。- パラメーター:
locator
-QueueBuilder.MasterLocator.minMasters
、QueueBuilder.MasterLocator.clientLocal
またはQueueBuilder.MasterLocator.random
。- 戻り値:
- ビルダー。
- 導入:
- 2.2
leaderLocator
public QueueBuilder leaderLocator(QueueBuilder.LeaderLocator locator)
ノードのクラスター上でキューマスターを配置するノードを決定するマスターロケーターモードを設定します。- パラメーター:
locator
-QueueBuilder.MasterLocator.minMasters
、QueueBuilder.MasterLocator.clientLocal
またはQueueBuilder.MasterLocator.random
。- 戻り値:
- ビルダー。
- 導入:
- 2.2
singleActiveConsumer
public QueueBuilder singleActiveConsumer()
"x-single-active-consumer" キュー引数を設定します。- 戻り値:
- ビルダー。
- 導入:
- 2.2.2
quorum
public QueueBuilder quorum()
queue 引数を設定して、型が "classic" ではなく "quorum" のキューを宣言します。- 戻り値:
- ビルダー。
- 導入:
- 2.2.2
stream
public QueueBuilder stream()
queue 引数を設定して、"classic" ではなく "stream" 型のキューを宣言します。- 戻り値:
- ビルダー。
- 導入:
- 2.4
deliveryLimit
public QueueBuilder deliveryLimit(int limit)
配信制限を設定します。クォーラムキューにのみ適用されます。- パラメーター:
limit
- 限界。- 戻り値:
- ビルダー。
- 導入:
- 2.2.2
- 関連事項:
quorum()
build
public Queue build()
最終キューを構築します。- 戻り値:
- Queue インスタンス。