Red Hat Training

A Red Hat training course is available for Red Hat Fuse

219.2.2. クエリーパラメーター(39 パラメーター):

Name説明デフォルトType

blockingExecutor (common)

SSL 接続は、setBlockingExecutor メソッドを呼び出して代わりに使用するエグゼキューターを設定する場合を除き、内部スレッドプールに対してブロッキング操作を実行します。

 

エグゼキューター (Executor)

byDefaultRetain (common)

MQTT ブローカーに送信されたメッセージで使用されるデフォルトの保持ポリシー

false

boolean

cleanSession (common)

MQTT サーバーがトピックサブスクリプションを永続化させ、クライアントセッション全体でのack の位置を保持する場合は false に設定します。デフォルトは true です。

false

boolean

clientId (common)

セッションのクライアント ID を設定するのに使用します。これは、setCleanSession(false)が使用されているセッションを識別するために MQTT サーバーが使用するものです。id は 23 文字以下である必要があります。デフォルトは、自動生成される ID です(ソケットアドレス、ポート、およびタイムスタンプに基づきます)。

 

文字列

connectAttemptsMax (common)

クライアントがサーバーに接続するために最初の試行時にクライアントにエラーが報告するまでの最大再接続試行回数。無制限の試行を使用するには、-1 に設定します。デフォルトは -1 です。

-1

Long

connectWaitInSeconds (common)

コンポーネントが MQTT ブローカーへの接続を確立するまで待機する遅延(秒単位)

10

int

disconnectWaitInSeconds (common)

MQTT ブローカーから stop()の有効な切断についてコンポーネントが待機する秒数

5

int

dispatchQueue (common)

HawtDispatch ディスパッチキューは、接続へのアクセスを同期するために使用されます。明示的なキューが setDispatchQueue メソッドで設定されていない場合、接続に新しいキューが作成されます。同期のために複数の接続が同じキューを共有する場合は、明示的なキューを設定すると便利です。

 

DispatchQueue

ホスト (共通)

接続する MQTT ブローカーの URI - このコンポーネントは SSL もサポートします(例: ssl://127.0.0.1:8883)。

tcp://127.0.0.1:1883

URI

keepAlive (common)

Keep Alive タイマーを秒単位で設定します。クライアントから受信されるメッセージの間隔を定義します。長い TCP/IP タイムアウトを待つことなく、サーバーへのネットワーク接続がドロップしたことをサーバーが検出できるようになります。

 

short

localAddress (common)

使用するローカルの InetAddress およびポート

 

URI

maxReadRate (common)

このトランスポートがデータを受信する 1 秒あたりの最大バイトを設定します。この設定では、レートを超えないように、読み取りをスロットルします。デフォルトは 0 で、スロットリングが無効になります。

 

int

maxWriteRate (common)

このトランスポートがデータを送信する最大バイトを設定します。この設定では、レートが超過しないように書き込みをスロットルします。デフォルトは 0 で、スロットリングが無効になります。

 

int

mqttQosPropertyName (common)

個別の公開されたメッセージの Exchange を検索するプロパティー名。これが設定されている場合(AtMostOnce、AtLeastOnce、または ExactlyOnce のいずれか)、その QoS は MQTT メッセージブローカーに送信されたメッセージに設定されます。

MQTTQos

文字列

mqttRetainPropertyName (common)

個別の公開されたメッセージの Exchange を検索するプロパティー名。これが設定されている場合(ブール値が必要)- retain プロパティーは MQTT メッセージブローカーに送信されたメッセージに設定されます。

MQTTRetain

文字列

mqttTopicPropertyName (common)

パブリッシュするエクスチェンジで検索されるこれらのプロパティー

MQTTTopicPropertyName

文字列

publishTopicName (common)

メッセージのパブリッシュに使用するデフォルトのトピック

camel/mqtt/test

文字列

qualityOfService (common)

トピックに使用するサービスレベル

AtLeastOnce

文字列

receiveBufferSize (common)

内部ソケット受信バッファーのサイズを設定します。デフォルトは 65536(64k)です。

65536

int

reconnectAttemptsMax (common)

サーバー接続が以前に確立された後にエラーがクライアントに報告するまでの最大再接続試行回数。無制限の試行を使用するには、-1 に設定します。デフォルトは -1 です。

-1

Long

reconnectBackOffMultiplier (common)

再接続試行間で使用されるExponential バックオフ。指数バックオフを無効にするには、1 に設定します。デフォルトは 2 に設定されます。

2.0

double

reconnectDelay (common)

最初の再接続試行までの待機時間(ミリ秒単位)。デフォルトは10です。

10

Long

reconnectDelayMax (common)

再接続試行まで待機する最大時間(ミリ秒単位)。デフォルトは 30,000 です。

30000

Long

sendBufferSize (common)

内部ソケット送信バッファーのサイズを設定します。デフォルトは 65536(64k)です。

65536

int

sendWaitInSeconds (common)

例外が発生する前に、コンポーネントが MQTT ブローカーからの受信を待機する最大時間。

5

int

sslContext (common)

SSLContext 設定を使用してセキュリティーを設定するには、以下を行います。

 

SSLContext

subscribeTopicName (common)

非推奨 化。これらは、MQTT から継承されたプロパティーとともに、エンドポイントで設定されます。

 

文字列

subscribeTopicNames (common)

メッセージをサブスクライブするトピックのカンマ区切りの一覧。この一覧の各項目には、階層内の特定のパターンに一致するトピックをサブスクライブするために MQTT ワイルドカード(または)を含めることができます。たとえば、階層内のレベルにあるすべてのトピックのワイルドカードであるため、ブローカーにトピック/トピックおよびトピック/2 がある場合は、topics/ を使用して両方をサブスクライブすることができます。ここで考慮すべき注意点として、ブローカーがトピック/3を追加した場合、ルートはそのトピックからメッセージ受信も開始することです。

 

文字列

trafficClass (common)

トランスポートから送信されるパケットの IP ヘッダーに、トラフィッククラスまたは type-of-service オクテットを設定します。デフォルトは 8 で、トラフィックがスループットに対して最適化される必要があることを意味します。

8

int

バージョン (common)

MQTT バージョン 3.1.1 を使用するには 3.1.1 に設定します。それ以外の場合は、デフォルトは 3.1 プロトコルバージョンです。

3.1

文字列

willMessage (common)

送信する Will メッセージ。デフォルトはゼロ長メッセージです。

 

文字列

willQos (共通)

Will メッセージに使用する QoS を設定します。デフォルトは AT_MOST_ONCE です。

AtMostOnce

QoS

willRetain (common)

Will を retain オプションを指定して公開するには、true に設定します。

 

QoS

willTopic (common)

クライアントの設定により、クライアントに予期しない接続が解除されている場合には、サーバーの Will メッセージを指定されたトピックに公開します。

 

文字列

bridgeErrorHandler (consumer)

コンシューマーの Camel ルーティングエラーハンドラーへのブリッジを許可します。よって、コンシューマーが受信メッセージなどの取得を試行している間に発生した例外は、メッセージとして処理され、ルーティングエラーハンドラーによって処理されます。デフォルトでは、コンシューマーは org.apache.camel.spi.ExceptionHandler を使用して例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。

false

boolean

exceptionHandler (consumer)

コンシューマーによるカスタム ExceptionHandler の使用を許可します。bridgeErrorHandler オプションが有効な場合は、このオプションは使用されていないことに注意してください。デフォルトでは、コンシューマーは例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。

 

ExceptionHandler

exchangePattern (consumer)

コンシューマーがエクスチェンジを作成する際に交換パターンを設定します。

 

ExchangePattern

lazySessionCreation (producer)

Camel プロデューサーの起動時にリモートサーバーが稼働していない場合に、例外を回避するためにセッションを遅延的に作成できます。

true

boolean

同期 (詳細)

同期処理を厳密に使用するか、Camel が非同期処理を使用できるようにするかを設定します(サポートされている場合)。

false

boolean