masstransit

    0

    1答えて

    私はMassTransit 3.4を使用し、EncryptedSerializerを使用しています。メッセージは暗号化され、アプリケーションによって正しく復号化されますが、RabbitMQの "_error"キューに表示されるbase64でエンコードされたメッセージをデコードできるようにしたいと考えています。私はbase64エンコードされたメッセージと暗号化されたメッセージの内容をユーザーが発見で

    0

    1答えて

    サービスバスの紺碧でMassTransit.Publishを呼び出すと、呼び出しがTransactionScopeにあるため例外があります。 The feature 'Transaction' is not supported with the current configuration トランザクションスコープ内でトランザクションモードなしでバスにメッセージを送信する方法はありますか? 私は

    0

    2答えて

    私はMassTransitを初めて使いました.Saga(MassTransitStateMachine)で定義した状態を、関連するSagaStateMachineInstanceの「State」プロパティにどのようにマップしているのか分かりません。クラス。例えば 、私は三つの状態とステートマシンクラスを持っている場合: public class MySaga : MassTransitS

    0

    1答えて

    次のコードはアプリケーションをクラッシュさせ、エラーは検出されず、を呼び出すとアプリケーションは単にシャットダウンします。 私が実際にやろうとしているのは、単体テストを実行することです。このコードは、きれいな例を提供するための抽象的なものです。対応するコードをunittestとして実行すると、スレッドが異常終了しているというエラーメッセージが表示されます。このコードは、MassTransitナゲッ

    0

    1答えて

    Consumer(およびバス)の量を制限するために、Consumer()/ Queueで処理をグループ化します。 しかし、コンシューマのメッセージを正しいオブジェクトにキャストするときに問題が発生します。 2種類のリクエストタイプを処理するコンシューマが1つあるとします。 2つのサブリクエストタイプは基本タイプから派生し、メッセージを派生タイプとして送信します。コンシューマメソッドはそれを基本タイ

    -4

    1答えて

    私は、メッセージを送信するためにMass Transitを使用しています。 public class Node { public Node Parent; public string Name; public List<Node> Nodes = new List<Node>(); } public class Portfolio : MessageBase

    1

    1答えて

    私はメッセージブローカーの初心者です。 私たちは複数のサブサービスを持つ発券サービスを持っています。スーパバイザサービスは、Web APIの助けを借りて要求を取得し、それらをサブサービスに送信します。 リクエストには、コマンドの種類(予約、払い戻し、空き状況など)を検出するためのヘッダーがあります。私たちはjsonを使ってオブジェクトを直列化します。 マストランスミットは、スーパバイザシステムなど

    0

    1答えて

    私の質問は次のとおりです:なぜScheduleRecurringMessageは時代遅れですか? その場合、定期的なメッセージの公開をスケジュールするにはどうすればよいですか? P.S new ScheduleRecurringSendメソッドはの代わりにの代わりにを送信します。

    2

    2答えて

    私はC#でMassTransitとrabbitMQを使用しています。 私は消費者にコマンドを送信し、コンシューマーでそれらを取得し、必要なタスクを実行し、パブリッシャーに応答を送信しようとします。 using MyCompany.Messaging; using System; using System.Threading.Tasks; namespace MassTransit.Rece

    0

    1答えて

    私はRabbitMQでMassTransitを使用し、Request-Responseアプリケーションを作成します。次に、私は複数の消費者から返された回答を受け取る方法を探します。 可能ですか?それが可能なら、どのように達成できますか? ありがとうございました。