問題タブ [consumer]

http://camel.465427.n5.nabble.com/FTP-ConsumerTemplate-Threads-remaining-alive-td5548338.htmlと非常によく似た問題があります。

異なるエンドポイントで Camel ロックされたスレッドをどのように強制終了しますか? doneUoW を設定した後、エンドポイントを削除して ConsumerTemplate を停止しようとしましたが、うまくいきませんでした。

.NET C# プロジェクトから以下の WSDL を使用して Web サービスを使用しようとしています。

Web 参照などを追加し、メソッド (getPatients) を呼び出してみましたが、常にエラーが返されます。

私は自分のコードは大丈夫だと思っていましたが（以前にうまく使っていたのと同じです）、何か間違ったことをしているに違いありません...

誰にもアイデアはありますか？

ありがとう

WSDL:

私は、OAuth2.0を使用するPHPでAPIを設計しているところです。私の最終目標は、このAPIに直接アクセスするJavaScriptで（AngularJSを使用して）フロントエンドアプリケーションを構築することです。従来、JavaScriptでトランザクションを保護する方法がないため、APIに直接アクセスすることはできません。フロントエンドはサーバーコードと通信する必要があり、サーバーコードはAPIと直接通信します。ただし、OAuth2の調査では、ユーザーエージェントフローがこの状況で役立つように設計されているように見えます。

私が助けを必要としているのは、JavaScriptでOAuth2ユーザーエージェントフローを実装することです（特に、フロントエンドに使用しているので、可能であればAngularJS）。これを行う例やチュートリアルを見つけることができませんでした。どこから始めればよいのか本当にわからないので、少なくとも私がやろうとしていることの例を見ずに、OAuth2仕様全体を読みたくありません。したがって、例、チュートリアル、リンクなどをいただければ幸いです。

私の Flex フロントエンドは、BlazeDS/Tomcat を使用してリアルタイム データを収集しています。
標準のストリーミング amf チャネルでプレーン コンシューマーを使用しています。

このセットアップは、以下を除くすべてのセットアップで問題なく機能します。目に見える不一致は次のとおりです。

• Windows 2008 サーバー vs Linux 以前の Windows
• Java 1.7.0 対 1.6.0
• Tomcat 7.0 対 6.0

症状は、 consumer.subscribedがtrueに設定されないことです。ただし、consumer.subscribe()が呼び出され、サーバー側で確認されます。

すべてのログ (catalina、stdout、および stderr) を確認しましたが、何が問題なのかについての目に見える手がかりはありませんでした。繰り返しますが、これとまったく同じセットアップが他のすべてのインスタンスで機能します

。何かアイデアはありますか?

サードパーティによって公開されたJMSキューがあります。異なるマシンに複数のコンシューマーをセットアップし、特定のマシンのコンシューマーを1つだけにして、そのキューのメッセージを確認したいと思います。つまり、特定のマシンのコンシューマーがメッセージを受信しない場合、そのメッセージをキューから削除しないでください。これは達成可能ですか？

ディスラプターの使用中に、遅れているコンシューマーが存在する可能性があり、その遅いコンシューマーのために、アプリケーション全体が影響を受けます。

すべてのプロデューサー (パブリッシャー) とコンシューマー (EventProcessor) がそれぞれ 1 つのスレッドで実行されていることを念頭に置いて、遅いコンシューマーの問題を解決するにはどうすればよいでしょうか?

単一のコンシューマーで複数のスレッドを使用できますか? そうでない場合、より良い代替手段は何ですか?

それで私は次の学校の課題を見ていました、そして私は困惑しています。ある方向で専門家のところに来ると思いました。同期に関する私の知識はひどく不足しており、それが参照する「mcopyfile」の割り当てについてはそれほど熱心ではありませんでした。ひどいことはおそらくそれのための良い言葉でしょう。この問題をどのように達成するかについて何らかの方向性を得ることができれば、それは大いにありがたいです。私の任務を遂行する人を探しているのではなく、正しい方向に私を向けてくれる人が必要です。赤ちゃんのステップ。

ラボ2で作成したマルチスレッドファイルコピーツール（mcopyfile）に基づいて、負荷を処理するために固定数のスレッドを使用するワーカープール（生産者/消費者モデル）の実装を使用してください（ファイルの数に関係なく）コピーするディレクトリ）。プログラムは、1つのファイルコピープロデューサースレッドと複数のファイルコピーコンシューマースレッドを作成する必要があります（この数はコマンドライン引数から取得されます）。ファイルコピープロデューサースレッドは、制限されたサイズのバッファー構造で（ソースと宛先の）ファイル記述子のリストを生成します。プロデューサーがバッファーにアクセスするたびに、1つの（ソース、宛先）ファイルエントリを（訪問ごとに）書き込みます。そして、すべてのファイルコピーコンシューマスレッドはこのバッファから読み取り、実際のファイルコピータスクを実行します。対応するファイルエントリを削除します（各コンシューマーは毎回1つのエントリを消費します）。プロデューサースレッドとコンシューマースレッドの両方が、ファイル名と完了ステータスを示すメッセージを標準出力に書き込みます（たとえば、プロデューサーの場合：「file1をバッファーに入れています」、コンシューマーの場合：「file1のコピーを完了しています…」）。

1つのプロデューサースレッドと複数のコンシューマースレッドを持つ次のコードがあります。複数のコンシューマーがスレッドセーフかどうか知っていますか。たとえば、スレッド1が消費している可能性がありますが、そのスレッド2は並行して消費し、スレッド1で使用されているアイテムの値を変更しますか？

前もって感謝します

メッセージを受信するたびに、コンシューマーにいくつかのアクションを実行してもらいたい。コンシューマーはキューを24時間年中無休で「リッスン」して実行する必要がありますか、それとも適切なメッセージを受信した場合にのみ実行できますか？