第116章 NAT
NATS コンポーネント リンクのコピーリンクがクリップボードにコピーされました!
リンクのコピーリンクがクリップボードにコピーされました!
NATS は、高速で信頼性の高いメッセージングプラットフォームです。
Maven ユーザーは、このコンポーネントの以下の依存関係を
pom.xml に追加する必要があります。
URI 形式 リンクのコピーリンクがクリップボードにコピーされました!
リンクのコピーリンクがクリップボードにコピーされました!
nats:servers[?options]
nats:servers[?options]
ここで 、サーバー は NATS サーバーの一覧を表します。
オプション リンクのコピーリンクがクリップボードにコピーされました!
リンクのコピーリンクがクリップボードにコピーされました!
|
名前
|
デフォルト値
|
説明
|
|---|---|---|
servers
|
null
|
コンポーネントが接続する必要のあるサーバーを定義します。
|
topic
|
null
|
サブスクライブ/パブリッシュするトピック。 |
reconnect
|
true
|
再接続機能を使用するかどうか。 |
pedantic
|
false
|
pedantic モードで実行するかどうか(これはパフォーマンスに影響します)。 |
verbose
|
false
|
詳細モードで実行するかどうか |
ssl
|
false
|
SSL を使用するかどうか |
reconnectTimeWait
|
2000
|
再接続を試みるまでの待機時間(ミリ秒単位) |
maxReconnectAttempts
|
3
|
接続が失われた場合の再接続試行の最大数を設定します。 |
pingInterval
|
4000
|
接続がまだ存続している場合を認識する ping 間隔(ミリ秒単位) |
noRandomizeServers
|
false
|
接続の試行のためにサーバーの順序をランダム化するかどうか。 |
queueName
|
null
|
キュー設定(コンシューマー)に NATS を使用している場合は、キュー名。 |
maxMessages
|
null
|
maxMessages (コンシューマー)の後にサブスクライブするトピックからメッセージの受信を停止します。 |
poolSize
|
10
|
コンシューマーワーカー(コンシューマー)のプールサイズ。 |
Headers リンクのコピーリンクがクリップボードにコピーされました!
リンクのコピーリンクがクリップボードにコピーされました!
| 名前 | タイプ | 説明 |
|---|---|---|
CamelNatsMessageTimestamp
|
long
|
消費されたメッセージのタイムスタンプ。 |
CamelNatsSubscriptionId
|
Integer
|
コンシューマーのサブスクリプション ID。
|
プロデューサーの例:
from("direct:send").to("nats://localhost:4222?topic=test");
from("direct:send").to("nats://localhost:4222?topic=test");
コンシューマーの例:
from("nats://localhost:4222?topic=test&maxMessages=5&queueName=test").to("mock:result");
from("nats://localhost:4222?topic=test&maxMessages=5&queueName=test").to("mock:result");