message-queue

0熱

1答えて

c＃メッセージメッセージキュー数。 - 排他的受信のために既にキューが開かれているために共有違反が発生しました

私のサーバーの1つにインストールされたメッセージキューのウォッチドッグを作成するのに忙しいです。私はキューでリッスンし、メッセージを処理しているアプリケーション（サードパーティ）を持っています。私は今それについて数えたいと思っており、メッセージが1500に達すると私は電子メールを送ります。だから私のコードは、メッセージキューを使うためにサードパーティのアプリケーションを閉じる必要があることを除いて

2熱

1答えて

パラメータ付きMassTransitアクティビティエラー

現在、CourierパターンのMasstransitを使用しています。私は失敗する可能性のあるアクティビティを設定しました。この失敗に同意し、それに応じて行動できるようにしたいと考えています。私の問題は、私が失敗を購読することはできますが、失敗の原因となった例外も見えますが、私はそれに引数を渡すことができません。テスト目的のために、私は以下の活性を有するsupose： public clas

0熱

1答えて

消費者はサービスバスに関するトピックをどのように扱うのですか？

私の製品は長いワークフロープロセスをバックグラウンドで実行する必要があります。私たちは、UIアプリケーションとAzureアプリケーションサービスに配備された別々の安らかなサービスを持っています。私たちは、安心して電話をかけることができないビジネス機能のために、このワークフロー（一部のタスクは並行して実行できる）を実装したいと考えています。だから、トピックを使っているサービスバスが行く方法です。サ

-1熱

2答えて

が消費者

を使用してwildfly JMSキューからメッセージを受け取るためにどのように節の問題が発生し、私のコードは打撃です： Session produceSession = connectionFactory.createConnection().createSession(false, Session .CLIENT_ACKNOWLEDGE); Session con

0熱

1答えて

プロデューサーはブローカーがメッセージを受け入れたことをどのように確認しますか？

JMSを正しく理解すると、コンシューマは仲介者に肯定応答を送信し、仲介者はコンシューマがメッセージを受け入れたことを理解します。しかし、どのようにプロデューサーは、ブローカーがメッセージを受け入れたかどうか確認しますか？私はAPIで何の謝辞も見ません。メソッドはsyncまたはasyncを送信しますか？

0熱

1答えて

メッセージは自動的にデッドレターチャネル（DLC）に移動されません - ブローカー - wso2 ei

メッセージブローカーでWSO2 EI 6.1.1を使用し、エンドポイントでメッセージストアとメッセージプロセスを含むメッセージキューを作成しようとしました。エンドポイントをシャットダウンすると、メッセージプロセッサが非アクティブになり、メッセージはキューに残り、DLCに移動されません。動作させるにはどうしたらよいですか？おかげで、ファリスShomou

1熱

1答えて

マルチトピックメッセージキュー

私は、マイクロサービスのアーキテクチャについてかなり理論的な質問があります。私たちは、RabbitMQを介してお互いに相互作用する2つのマイクロサービスAとBを持っているとします。 Aに質問がある場合、queue_1にメッセージを送信し、Bからqueue_2までの回答を受信します（このように通信は非同期になります）。 ------------ ---> queue_1 --->

0熱

1答えて

カフカの深いヘルスチェック

最近、カフカブローカーがIOをブロックしたカーネルの問題に遭遇した（ただし、私が推測するように動物園に戻ってきたことに心を打つことができた）問題が発生しました。この結果、KafkaブローカーはISRセットにとどまっていましたが、実際には何の作業も完了できませんでした。質問です： 1）は、ハートビートを発する前に、カフカがチェックするものを上の任意の文書があり、またはそれだけで発光ハートビートをd

0熱

2答えて

私はJavaでそれを実装し、エンドポイントのコンストラクタを持ちたいデフォルトポート

を設定する際のRabbitMQは接続を拒否： public EndPoint(final String endPointName, final String host, final int port){ this.name=endPointName; ConnectionFactory factory = new ConnectionFactory(); facto

1熱

1答えて

CQRS実装のためにMasstransitをラップするのは良い方法ですか？

ようOrderEventHandlerクラスが見えるように私はむしろCommandBus別々とEventBusともICommandHandler<TCommand>とIEventHandler<TCommand>を持っているでしょう： public class OrderEventHandler : IEventHandler<OrderPlaced>, IEventHandl