masstransit

0熱

1答えて

Azure Service Busの機能を頭に入れようとしています。私は、異なる環境（開発、テスト、ステージングなど）にアプリケーションをデプロイしています。私が見たことから、バスごとに1つのメッセージタイプしか持てませんか？それぞれの環境をサポートするためには、サービスバスの別のインスタンスが必要なのでしょうか？私はMasstransitを使用しています。標準バージョンのサービスを実行する必要が

0熱

1答えて

Masstransit ReceiveFromメソッドと消費者の動作によって混乱しました

私は片面にいくつかのメッセージを送信し、別のアプリケーションで受信するRabbitMqでキューを作成したいと思います。 I'amは、次のコードでこれを行う： return ServiceBusFactory.New(x => { var uriString = string.Format(@"rabbitmq://{0}/{1}/{2}?prefetch={3}", ho

1熱

1答えて

Masstransit/RabbitMQでキューを整理する方法は？

メッセージを消費するためのベストプラクティスについて知りたい。私はMassTransitのドキュメントを読んできましたが、これについて検索しましたが、結論には至りません。メッセージを公開しているapi（バスインスタンスのホスト）が1つあります。このAPIはマイクロサービス（購入、販売などのメッセージ）ではないため、これらのメッセージはさまざまです。コンシューマ/キューをどのように整理する必要が

0熱

1答えて

InMemoryTestFixtureを使用してMassTransitコンシューマをテストする

さまざまなコンテンツを持つコンシューマメッセージを送信できるMassTransitコンシューマの周りにテストを設計したいと考えています。消費者がメッセージを中継してメッセージを中継するメッセージの内容に基づいています。私が持っている問題は、別々のテストフィクスチャで2つのテストを実行しているときに、2つ目のテストを妨害しているようです。しかし、個々のテストを個別に実行すると、正常に実行されます

1熱

2答えて

長期リトライポリシーに伴うメッセージの処理

MT専門家のご挨拶。私のアプリでは、合計30分間合計3分ずつメッセージを送信するデフォルトの再試行ポリシーがあります。また、このポリシーの影響を受ける（16以上の）失敗したメッセージが多数ある場合、他のメッセージは処理されません（成功したメッセージであっても）。これは大きな問題です.16個のメッセージが壊れていると、キュー全体が30分間ブロックされるためです。解決策はありますが、私は何も見つか

0熱

1答えて

RabbitMQのは、私たちは私たちが次のシナリオを持っていることを言わせて、応答がnull

であれば、私は異なるサービス間でのメッセージングのためのmasstransitでのRabbitMQを使用しています要求を再送信しています要求。 2番目のサービスは、データベース内の情報を探し、見つかった情報を含むオブジェクトで応答します。データベースで利用可能な情報がない場合、2番目のサービスはnullオブジェクトで応答します。問題はRabbitMQが要求が失敗したとみなしているため、要求を再

-1熱

1答えて

Masstransitで消費者に依存関係を注入する方法

私の消費者コードを以下に示します。イベントが発行されたときに 'このオブジェクトに対して定義されたパラメータのないコンストラクタはありません。'例外がスローされます（詳細は下記参照）。 Microsoft.Extensions.DependencyInjectionコンテナのみを使用しています。どうすれば依存関係を注入できますか？このためのコードサンプルがあります。 public class Us

0熱

1答えて

耐久性と一時的なサブスクリプション

RabbitMQとMassTransitを使用したpub/subメッセージングを使用して複数の.Netモジュールを統合しています。メッセージサブスクリプションのほとんどは耐久性があります。しかし、一部は一時的である。消費者が死亡した場合、メッセージは保存されず、すでにキューに入れられたメッセージは破棄される。各モジュールでは、2つの受信エンドポイントで1つのバスを作成します。 1つは、耐久性のあ

2熱

1答えて

例外時の佐賀のファイナライズ

私は佐賀を作成し、アクティビティの実行中に例外を処理する方法を知りました。理想的には、私は場合によってはそのサガインスタンスを殺すために、すぐににしたいと思います。私はこのスレッドにつまずいた：Understanding "Finalize" in MassTransit、私の現在のアプローチは少し異なります。で私はSagaFaultedEventとFaulted状態への遷移を公開： .

0熱

1答えて

サービスイベントとコマンドとの間のメッセージ

サービス間のメッセージングに使用されるさまざまな方法を理解しようとしています。私は、ユーザーが製品の作成を依頼したことを他のユーザーに知らせるための最初のサービスが必要なシナリオを持っていて、2番目のサービスはこのメッセージを受け取って製品を作成し、製品が作成されました。最初のサービスが別の特定のサービスに対処する必要があり、フィードバックを待つため、要求/応答とともにコマンドがこのシナリオ