masstransit

0熱

2答えて

IBusControl別のクラスにラップされている間はパブリッシュは何もしません

私はMassTransitに苦労しています。私がまだ解決できなかったもう一つの難しい問題です。 Publishメソッドを直接呼び出すと、すべて正常に動作し、メッセージがRMQに送信されます。しかし、私は自分自身でこのメソッドをラップし、ラッパークラスのコンストラクタでバスを注入すると、うまくいきません。メッセージは単にバスには届かない。 using (var uow = new Wrapper(c

2熱

1答えて

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

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

0熱

1答えて

マストランジットメッセージの消費順

私は公開エンドポイント 'P'と2人の消費者 'A'、 'B'を持っています。 'P'がメッセージ '1' '2' '3'を発行すると、消費者は '123'の順番でメッセージを消費することが予想されます。しかし実際には、消費順序はおそらく '132'、 '312'などとなります。私は並行処理に関連する設定を構成しているが、それは concurrency settings 質問動作しません：「A」

0熱

1答えて

MassTransitの「ファイナライズ」の理解

MassTransitでFinalize（）がどのように機能しているか、特に初期状態で実行できるかどうかを理解する上で問題があります。セットアップ：私はHandleCrawlRequestCreatedで例外をキャッチした場合 public Event<ICrawlRequestCreated> CrawlCreated { get; private set; } public Event Cr

0熱

1答えて

テストmasstransit消費者

私はこのように私の消費者の表情masstransitの消費者をテストしようとしています： public class FilePolicyEvaluationConsumer : IFilePolicyEvaluationConsumer { public readonly IFilePolicyEvaluationCore _filePolicyEvaluationCore;

1熱

1答えて

RabbitMQの消費者は消費しない理由は、StartAndNextCommandの

public class RequestConsumer : IConsumer<StartFlowCommand>, IConsumer<List<StartAndNextCommand>> { readonly IWorkFlowHandler _flowHandler; public RequestConsumer(IContainer contai

1熱

1答えて

マストトランジットエラーキューが消費されていますが、まだ空ではありません

私はRabbitMqでMastransit 3.5.0を使用しています。キューコンシューマが例外をスローすると、そのコンシューマはデフォルトでMoveExceptionToTransportFilterによって処理され、_errorキューに移動されます。 _errorキューの場合、別のコンシューマがあります。コンシューマ（ConsumeContext>コンテキスト）フォールトの動作はかなり異な

1熱

1答えて

vhostへのアクセスがMassTransit Sample-RequestResponseサンプルで

最新のRabbitMQサーバー（ゲストはadmin）でデフォルト設定を使用していますが、RequestResponseサンプルを実行すると次の例外が発生します。 OperationInterruptedException：AMQP操作は中断されました：AMQPクローズ理由は、ピア、コード= 530によって開始され、テキスト= "NOT_ALLOWED - バーチャルホストへのアクセス 'テスト'

1熱

1答えて

masstransit sagaに公開されたイベントのヘッダーにアクセスする方法はありますか？

このようなイベントを公開したときに、佐賀のヘッダーにアクセスする方法はありますか？ await busControl.Publish<IOrderCreated>(new { OrderId = dto.Id }, context => { context.Headers.Set(LogConstansts.Common.Operat

0熱

1答えて

Autofac＆MassTransit - Consumer ObjectDisposedExceptionを登録します。

コンテキスト：ASP.NET Core App（1.1）。私はコンシューマーインスタンスが必要なときに既に登録したIRepositoryを解決しようとしますが、ObjectDisposedExceptionが表示されるようです。私は私がContainerBuilderの.Build()メソッドを呼び出したときに自動アクティブバスファクトリメソッドを作成しました。 public IService