masstransit

0熱

1答えて

受信メッセージをコンシューマに渡す前に、受信メッセージを検証する必要があります。これを行うには、データベースからデータを要求する必要があります。チュートリアルに続いて、私の仕様+フィルタをコンシューマパイプに適用する拡張メソッドを作成しました。このような何か： public static void UseArticlesImportValidation(this IConsumePipeCon

2熱

1答えて

スキップされたキュー内のメッセージの取得

スキップされたキュー（mtSubscriber_creditAuthRequest_queue_skipped）に応答メッセージ（CreditAuthorizationResponse）が表示される理由を理解できますか？送信者は期待通りに応答を受信していますが、スキップされたキューにも移動しています。私はスキップされたキューに入るメッセージを除き、期待どおりに動作している以下の消費者が、作成

2熱

1答えて

MassTransitとサービスファブリックステートフルサービス？

私は、RabbitMQでMassTransitを使用してステートフルサービスとしてService Fabric上で動作しているサービスにメッセージを投稿するウェブサイトのデモを考えてきました。 IBusControl bus = BusConfigurator.ConfigureBus(); Uri sendToUri = new Uri($"{RabbitMqConstants.RabbitM

0熱

1答えて

RabbitMQに診断情報を記録する

現在、Nlogを使用して診断タイプのメッセージを保存しています。私は、これらのメッセージをメッセージキュー（RabbitMQ with Masstransit）に記録することを検討しており、これらは分析のためにデータベースに消費される可能性があります。私のPC上でメッセージをログに記録/公開する現在の速度は、次のとおりです。 - Nlog：petapoco経由40msの SQL Serverの：

0熱

1答えて

CreateQueues and Exchanges - MassTransit

私はRabbitMQでmassTransitを使用しています。 massTransitでメッセージを公開すると、自分のメッセージタイプの交換が作成されます。そして、masstransitの消費者は、キューと交換のバインディングを作成します。素晴らしい、物事を簡単にする。 massTransitを見る前に、キュー、交換、バインディングを作成するためにrabbitMQのapiを使用しました。同じセット

0熱

1答えて

MassTransit同じプロセスで実行されている2つの異なるアプリケーションのメモリ設定時

2つのアプリケーションのそれぞれに対してAppDomainを作成することによって、同じプロセスで実行されている2つの異なるアプリケーションがあります。アプリケーション2のバス設定は次のようになります builder.Register(c => { var inMemoryTransportCache = new InMemoryTransportCache(Envir

0熱

1答えて

Masstransitでデッドレターメッセージキューを設定する

リクエスト/レスポンスパターンを持つMasstransitを使用しています。このキューに関連するデッドレターメッセージキュー名とその他の設定を使用したい場合は、UseDeadLetterQueue拡張メソッドタイプIPipeConfiguratorに設定する必要がありますが、私が設定しなければならないタイプはReceiveEndpointメソッドのIRabbitMqReceiveEndpointC

0熱

1答えて

.NETアプリケーションで応答しないRabbitMQを検出して処理する

最近、私たちのウサギクラスターに人為的に負荷がかかるため、私たちのAPIの1つが応答しなくなったところで停止しました。モノラル（.NET）のスレッドが不足し、APIへのリクエストが失敗しました。これが再び起きることはまずありませんが、これに対して何らかの防御を施したいと考えています。理想的には、bus.Publish（）の呼び出しには一定の時間が経過した後にタイムアウトすることがありますが、どのよ