public final class QueueBuilder extends AbstractBuilder
| 修飾子と型 | クラスと説明 |
|---|---|
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 | 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 | ttl(int ttl) メッセージの有効期限を設定してから破棄するか、構成されている場合はデッドレター交換にルーティングします。 |
QueueBuilder | withArgument(StringSE key, ObjectSE value) 最後のキューには、キューを宣言するために使用される引数が含まれます。 |
QueueBuilder | withArguments(MapSE<StringSE, ObjectSE> arguments) 最後のキューには、キューを宣言するために使用される引数が含まれます。 |
getArguments, getOrCreateArgumentscloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEpublic static QueueBuilder durable()
spring.gen-<random> を持つ永続キューのビルダーを作成します。public static QueueBuilder nonDurable()
public static QueueBuilder durable(StringSE name)
name - キューの名前。public static QueueBuilder nonDurable(StringSE name)
name - キューの名前。public QueueBuilder exclusive()
public QueueBuilder autoDelete()
public QueueBuilder withArgument(StringSE key, ObjectSE value)
key - 引数名 value - 引数値 public QueueBuilder withArguments(MapSE<StringSE,ObjectSE> arguments)
arguments - 引数マップ public QueueBuilder ttl(int ttl)
ttl - 存続時間 (ミリ秒)。deadLetterExchange(String)public QueueBuilder expires(int expires)
expires - 有効期限 (ミリ秒)。public QueueBuilder maxLength(int count)
count - 許容される (準備完了の) メッセージの数。overflow(Overflow)public QueueBuilder maxLengthBytes(int bytes)
bytes - 総集合体サイズ。public QueueBuilder overflow(QueueBuilder.Overflow overflow)
overflow - QueueBuilder.Overflow.dropHead または QueueBuilder.Overflow.rejectPublish。public QueueBuilder deadLetterExchange(StringSE dlx)
dlx - デッドレター交換。deadLetterRoutingKey(String)public QueueBuilder deadLetterRoutingKey(StringSE dlrk)
dlrk - 配信不能ルーティングキー。deadLetterExchange(String)public QueueBuilder maxPriority(int maxPriority)
maxPriority - 最大の優先度。public QueueBuilder lazy()
public QueueBuilder masterLocator(QueueBuilder.MasterLocator locator)
locator - QueueBuilder.MasterLocator.minMasters、QueueBuilder.MasterLocator.clientLocal または QueueBuilder.MasterLocator.random。public QueueBuilder singleActiveConsumer()
public QueueBuilder quorum()
public QueueBuilder deliveryLimit(int limit)
limit - 限界。quorum()public Queue build()