masstransit

0熱

1答えて

信頼性の低いネットワーク環境でMassTransitを設定するにはどうすればよいですか？

私はRabbitMQと組み合わせてMassTransitの周りに頭を上げようとしています。基本的なコンセプトはテストプロジェクトで作業していますが、必要なものは次のとおりです。私のシステムには、実際の出来事（電話）に反応する1台以上のサーバーがあります。これらのイベントは、MassTransitとRabbitMQを使用して、RabbitMQホストとしてセットアップされた別のサーバーを介して1つ

0熱

1答えて

MassTransitを3.4.0から3.3.1にダウン

私はMassTransitとMassTransitへのDLL参照を3.4.0から3.3.1にダウンロードしようとしています。私はすべてのインスタンスをNugetシェルに置き換え、3.4.2 AsmSpyの参照インスタンスがもうないことを確認しました（MassTransitとMassTransitは常に3.3.1として参照されます）。それにもかかわらず Reference: MassTransit

0熱

1答えて

Use MassTransitとの間隔を設定する

MassTransitとAzure Service Busをトランスポートとして使用して、間隔設定でUseRetryを使用しようとしています。コンシューマーコード： public async Task Consume(ConsumeContext<ISimpleRequest> context) { _log.InfoFormat("Strated working on {

1熱

1答えて

MassTransit RabbitMQエラーキューの消費メッセージの半分をError_Skippedキューに移動する

メッセージをエラーキューから元のキューに戻そうとしています。これを行うには、エラーキューにコンシューマを作成し、それを必要なキューに公開しました。これを試してみると、Consumed Messagesの半分が公開されますが、残りの半分はError_Skipped Queueに送信されます。私は多くのことを成功させずに試してきました。だから、おそらく私が紛失している単純なものです。は、ここに

3熱

1答えて

MassTransit RabbitMQの処理方法

断続的なRabbitMQ接続の問題やRabbitMQの完全な停止を処理するために、MassTransitをフォールトトレラントに設定する適切な方法は何ですか？ 2つの異なるマシン間にRabbitMQクラスタを設定し、すべてをミラー化するようにHAを設定しました。また、F5ロードバランサをアクティブ/パッシブモードに設定して、すべてのトラフィックがプライマリノードに送信されるようにしますが、ヘルスチ

1熱

1答えて

masstransitハンドルは/私がメッセージを消費するの明確な理解を持っているバッチ

内のメッセージを消費します。一度に複数のメッセージを一括してバッチで処理する必要があります。

0熱

1答えて

MassTransit同じキューに入ってループが発生する

MassTransitのために現在NServiceBusを切り替えていますが、リクエスト/応答パターンに少し問題があります。では、私はHandlerで返信でき、送信したクライアントに戻ります。応答は、このようにループを作成し、バックそれはから消費されたことをキューに送信されているかのようにそれが表示されます MassTransitで、... 奇妙なことに、私はインメモリを使用してバスを作成して

0熱

1答えて

MassTransitを使用して長時間動作させるには？

私は輸送としてMassTransitとAzure Service Busを使用しています。長時間の操作（1〜18時間）で、Azureサービスバスのロックタイムアウトを嫌う方法はありますか？

2熱

1答えて

MassTransitは、キューがダウン

私はMasstTransit 3.2.0とRabbitMQの3.6.0を使用して、次のようにそれを設定していたときスタート/ストップの処理方法： // MassTransit IBusControl bus = Bus.Factory.CreateUsingRabbitMq(cfg => { var host = cfg.Host(new Uri(configuration.Url)

0熱

1答えて

MassTransitでランダムなデータを持つ定期的なメッセージをスケジュールする

私はMassTransitで定期的なメッセージをスケジュールしたいが、メッセージがキューに送られるたびに同じランダムなデータを生成したい。今の私はそのようなコードを持っている var scheduleEndPoint = await _bus.GetSendEndpoint(new Uri($"{BusConstants.RabbitMqUri}/quartz")); await