問題タブ [oracle-aq]

Oracle AQ で Reactive 拡張機能を使用しようとしています。メッセージがOracle Queueに到着すると、「OracleAQMessageAvailableEvent」が起動され、メッセージがあることがコンシューマに通知されます。OracleAQMessageAvailableEventHandler 内で、コンシューマは OracleAQQueue.Dequeue() をコールしてメッセージを取得します。

RXで上記の作業を行いました。以下は私が使用したコードです。

問題は、すべてが機能したらメッセージをサブスクライブすると、メッセージを複数回サブスクライブすると (つまり、アプリケーション内の複数のコンシューマー)、すべてのコンシューマーが「_queue.Dequeue()」を呼び出そうとし、最初の呼び出し以降のすべての呼び出しが失敗することです。新しいメッセージがない場合。

誰か私が何をすべきか教えてください。私のシナリオは Hot Observable 向けだと思いますが、頭を悩ませています。

サブスクライバがマルチコンシューマ・キューからデキューしたメッセージを Oracle Advanced Queuing が追跡する方法は?

USER_QUEUE_SUBSCRIBERS テーブルは、キューごとのサブスクライバーを追跡します。特定のキューのサブスクライバーの状態を追跡するテーブル/ビューが見つかりません (たとえば、サブスクライバーがデキューした最後のメッセージは何でしたか?)。

Oracle AQ マルチコンシューマ キューに接続するクライアント アプリケーションがあります。OracleAQQueue.Listen を使用して、キューの新しいメッセージをリッスンしたいと考えています。 API ドキュメントは、Listen メソッドをマルチコンシューマ キューに使用できることを示しています。キューをリッスンするための私のコードを以下に示します。

私が抱えている問題は、queue.Listen() を呼び出すコード行で、Oracle 例外が発生することです。

この特定のエラーに関するアドバイスをグーグルで検索しても、あまり役に立ちませんでした。サブスクライバーをキューから削除して再追加しましたが、役に立ちませんでした。私の推測では、Listen を呼び出す前に一部のプロパティを正しく設定していないのですが、問題がわかりません。

何か案は？

Jboss eap 6.3 と jms の Hornetq キューで動作するアプリケーションがあります。キューを hornetq から OracleAQ に変更する必要があります。それを接続する準備ができているリソースアダプターはありますか、それとも自分用に新しいリソースアダプターを作成する必要がありますか? どうすればそれを達成できるかについてのヒントに感謝します。前もって感謝します。

Oracle 12c 64 ビット ODP.NET クライアントを使用して、Oracle 12c データベースで AQ を操作しています。データベースに接続して操作することはできましたが、メッセージをデキューするときにデータの破損やアクセス違反の例外 (AVE) が発生することがありました。AVE はアプリケーションを不適切な方法で終了させます。

Windows Server R2 2012 標準 64 ビットを実行しているマシンから接続しています。IDE は Visual Studio Professional 2015 です。

この問題について何か助けていただければ幸いです。32ビットクライアントの使用など、いくつかのことを試します

イベント ログから:

タイプ SYS.AQ$_JMS_TEXT_MESSAGE のキューに入力する必要がある C++ で作成されたアプリケーションがあります。

C++ API である OCCI を使用して Oracle データベースを操作していますが、他のタイプのキューを正常に作成しました。

OCCIを使用してSYS.AQ$_JMS_TEXT_MESSAGEタイプのキューを移入できますか?