masstransit

    0

    1答えて

    私が消費するすべてのメッセージをMassTransitに記録したいと思います。収入メッセージを処理したり、設定を使って達成できるグローバルインターセプタを実装する方法はありますか? 私の現在の設定は次のようになります。 BusFactory = Bus.Factory.CreateUsingRabbitMq(cfg => { var host = cfg.Host(new Uri(Ap

    1

    1答えて

    組み込みのインターフェイスCorrelatedBy<TKey>を使用してメッセージを追跡したいのですが、 ? public class RegisterCallback : IRegisterCallback { public RegisterCallback() { CorrelationId = Guid.NewGuid(); } pub

    2

    1答えて

    バスにコンシューマがないC#とRabbitMQを使用して、MassTransit v3でパブリッシュ専用バスを実装しようとしています。このコンセプトは、メッセージが公開され、キューに入れられると、別のマイクロサービスがキューからメッセージを消費します。 this SO answerを見ると、メッセージが実際にキューに入れられるように受信エンドポイントを指定する必要があります。しかし、これはcont

    0

    1答えて

    私はメッセージングフレームワークとして、Azure Service Bus上で動作するMassTransitを使用しています。私はWebJobの中からMassTransitを実行しています(問題はないと思いますが) 私は現在、複数のメッセージを同時に処理するよう努めています。処理するのに時間がかかります。したがって、パフォーマンスを向上させるために、私は各メッセージを1つずつ処理する必要はありませ

    1

    1答えて

    MassTransitアプリを2.xから3.xに更新し、RabbitMQに切り替えました。私は、以前の開発者がMSMQで動作すると思っていた1対多のメッセージングを正しく機能させるためにこれを行いましたが、動作していないことが判明し、3.xとRabbitMQ 。 私のアプリケーションには、Webサイトの複数のインスタンスがサーバー上で実行されており、各インスタンスは特定の顧客ベースに対応しています

    0

    1答えて

    メッセージがキューに配信されない場合は、MassTransitを使用してRabbitMQ交換に送信する際に例外を取得したいと考えています。このようなものにはRabbitMQ必須フラグが使用できるようですが、MassTransitを使用してこれを設定する方法はありませんでした。これはサポートされていますか? マイコード: var personSendEndpoint = busControl.Get

    0

    1答えて

    私はこの public Task Consume(ConsumeContext<Message1> context) { context.GetOrAddPayload(() => new Payload()); return context.Publish(new Message2()); } ようConsumeContextにカスタムペイロードを追加し、メッセージ2

    1

    1答えて

    私はAzureSerivceBusで作成された名前空間を持っています。 Azure APIを使用して直接、トピックを作成してメッセージを送信することができます。 今、MassTransitを抽象レイヤーとして使用してトピックを作成したいと考えています。これは、ローカルインストールの場合、RabbitMqを使用し、MassTransitは良好な抽象化を提供するためです。現在、同じコードをCloud(

    0

    1答えて

    私は、rabbitmq/apiを使用してリモートホストからrabbitmqにメッセージを公開するケースがあり、私はMassTransitの消費者に公開されたメッセージの処理を渡したいと思います。 は、私が気づく可能性として、MassTransitの消費者との成功の「最小限必要なプロパティ」扱いのメッセージは次のようになります。 ペイロード: { 'messageId':'86fd0000

    0

    1答えて

    MassTransit with RabbitMQに関する質問。 2つのメッセージの間に依存関係を作成する必要があります。メッセージ1が完了した後 1)新しい契約 2の作成)更新ContractOptions 第2のメッセージにのみ実行することができます。 どうすればいいですか?