第261章 PostgresSQL Event Component

Camel バージョン 2.15 以降で利用可能

これは、PostgreSQL 8.3 以降に追加された LISTEN/NOTIFY コマンドに関連する、Producing/Consuming PostgreSQL イベントを可能にする Apache Camel のコンポーネントです。

Maven ユーザーは、このコンポーネントの pom.xml に以下の依存関係を追加する必要があります。 

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-pgevent</artifactId>
    <version>x.x.x</version>
    <!-- use the same version as your Camel core version -->
</dependency>

URI 形式

pgevent コンポーネントは、次の 2 つのスタイルのエンドポイント URI 表記を使用します。 

pgevent:datasource[?parameters]
pgevent://host:port/database/channel[?parameters]

URI には、?option=value&option=value&…​ の形式でクエリーオプションを追加できます。

261.1. オプション

PostgresSQL Event コンポーネントにはオプションがありません。

PostgresSQL Event エンドポイントは、URI 構文を使用して設定されます。 

pgevent:host:port/database/channel

パスおよびクエリーパラメーターを使用します。

261.1.1. パスパラメーター (4 パラメーター)

名前説明デフォルトタイプ

host

ホスト名とポートを使用してデータベースに接続します。

localhost

String

port

ホスト名とポートを使用してデータベースに接続します。

5432

Integer

database

必須 データベース名

 

String

channel

必須 チャンネル名

 

String

261.1.2. クエリーパラメーター (7 個のパラメーター):

名前説明デフォルトタイプ

datasource (Common)

ホスト名とポートを使用する代わりに、指定された javax.sql.DataSource を使用して接続します。

 

DataSource

bridgeErrorHandler (consumer)

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

false

boolean

exceptionHandler (consumer)

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

 

ExceptionHandler

exchangePattern (consumer)

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

 

ExchangePattern

synchronous (advanced)

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

false

boolean

pass (security)

ログイン用パスワード

 

String

ユーザー (security)

ログイン用のユーザー名

postgres

String