masstransit

1熱

1答えて

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

1熱

1答えて

デッドレターメッセージがあるときにスキップされたキューを作成しない

要求/応答シナリオで_skippedキューを作成しないように選択できますか？私たちはこのようなアプリを構築することを選択しました（理由は分かりません）。私たちは複数の消費者に対してPublishRequestを実行しており、1人の消費者だけが応答しています。他のすべてはスキップされたキューを生成します（タイムアウトエラー）。私はこの構造を変えたくありません。しかし、RabbitMQでスキップされ

0熱

1答えて

MassTransitコンシューマが同じイベントを消費する順序を指定します。

同じタイプのイベントを消費する2つのコンシューマ：FirstConsumerおよびSecondConsumerがあります。しかし、SecondConsumerからの操作は、FirstConsumerによって実行される操作の出力に部分的に依存する。 SecondConsumerにより、イベントが常にがFirstConsumerによってのみそれが行われています後、最初に消費されることを確実にする方法は

0熱

1答えて

読み取り操作のためにデータベースを照会する際のガイダンスは、タイムバウンド操作のための一括転送要求/応答を使用して行う必要があります。

作成操作では、メッセージをキューに入れることは、そのメッセージの処理または作成エンティティは予想以上に時間がかかり、その他のメリットキューには時間がかかります。ただし、タイムアウト（3秒未満でUIに戻る必要があります）の読み取り操作では、キューが有効かどうかは完全にはわかりません。 http://masstransit-project.com/MassTransit/usage/request-

0熱

2答えて

masstransit deferred in sagas

私は、複数のサービスにわたって活動を編成するために、大量輸送中のサガを使用して調査しています。サーガの生涯は短く、すべてがうまくいくならば2秒以下です。私の場合、クライアントがコマンドを要求し、サガがそのコマンドを処理し、メッセージが受信されて最終的に最初のコマンドに応答するような状態変更を行う要求/応答アプローチを使用したいと思います。サガを開始し、その時点でクライアントはレスポンスを受け取り

0熱

2答えて

プリフェッチ回数を動的に設定する方法RabbitMq

プリフェッチ回数を動的に設定することは可能ですか？ここで私は達成したいと思ったものです。私はキューの加入者であるサービスを持っています。私は、プロセッサの使用量、RAMなどのサービスリソースを監視しているメカニズムを持っています。このメカニズムは、このリソースが多く使用されるときにサービスに通知します。だからこの通知が来たら、私はキューからのメッセージの取得をやめたい。それはキューから退会すること

0熱

1答えて

メモリ内のマストトランストラスト消費者の実行を待つテスト

したがって、メモリ内機能を使用して一括転送のテストを作成しようとしています。私は、人々がアプローチするのは、消費者が実行するのを待つことだと思った。以下の例では、睡眠を使用するか、私もwhileループを試しましたが、どちらのファンでも良いアイデアはありませんか？私は基本的に消費者が実行されていることを確認したい。 [Fact] public async Task SomeTest() {

0熱

1答えて

サガからルーティングスリップを実行するにはどうすればよいですか？

私たちはワークフローをモデル化するためにサガを使用しています。このワークフローは、イベントが来るのを待って、イベントに基づいて何らかの作業を実行します。いくつかのケースでは、複数のタスク（連鎖されたメソッド）を順番に実行する必要がありますが、失敗した場合はチェーン全体を補完したいと考えています。ルーティングスリップは適切だと思われますが、そのようなルーティングスリップがサガのThenメソッドから実

0熱

1答えて

MassTransitのバスキューとは何ですか？

消費者が受け取るエンドポイントに接続すると、一意の名前の交換・キューは、このようなとして作成されます。このキュー/交流の目的は何 bus-{MachineName}-{ApplicationName}-{Identifier} ？これを詳述している文書はありますか？

0熱

1答えて

ヘルスチェックMassTransitとRabbitmq

ASP .netコアアプリケーションでヘルスチェックミドルウェアを実装する予定です。たとえば、DBが健全かどうかを確認するには、db接続を開いて閉じます。同様に、MassTransitが正常であるかどうかを確認する最良の方法は何ですか（問題なくメッセージを送受信して送信することができますか？あなたのヘルスため