easynetq

1熱

2答えて

AutofacとEasyNetQの単位はで動作するように簡単に、ほぼすべての時間ですが、今日、我々は挑戦のようなものを持っている：私は加入者に仕事の単位を設定したい class Program { static void Main(string[] args) { var container = AutofacContainerFactory.Bui

0熱

1答えて

EasyNetQメッセージパブリッシャーパターン

EasyNetQのラッパーを作成して、RabbitMQにメッセージを公開しています。公開する必要のあるメッセージが多数あります。 IBusを使用してメッセージをパブリッシュするためにパターンを使用すべきか、IBusタイプvarをクラス・レベルの静的varとして宣言する必要がありますか？アプリケーション終了時に破棄しますか？ using (IBus bus = RabbitHutch.CreateB

0熱

2答えて

デッドレターがタイプを変更した場合、どのようにデッドレターメッセージをデシリアライズしますか？

デッドレターキューからメッセージを読み込み、タイプ、内容などに基づいてメッセージで何かを行うデッドレターハンドラーサービスを作成しようとしています。私のC＃アプリケーションでは、 EasyNetQを使用します。私は、MyMessageと呼ばれる基本的なメッセージタイプを持ち、次にいくつかのサブタイプを持っています。 EasyNetQには、メッセージのシリアライズ、交換への送信、キューからの取り出

0熱

1答えて

コンシューマーからのACKで小さなタスクを含むタスク

私はいくつかのPOC projectに取り組んでおり、次の問題を解決しようとしています。私はキューにメッセージを送信しているPublisherを持っています。必要に応じて bus.SubscribeAsync<IBaseScenario>("test_1_consumer", message => Task.Factory.StartNew(() => {

0熱

1答えて

RabbitMQ - Subscriberサービスが何らかのエラーで失敗したときにPublisherサービスを停止する方法

C＃で2つのWindowsサービスがあります。サービス1は、メッセージをRabbitMQキューにパブリッシュします。サービス2は、RabbitMQキューにサブスクライブします。サービス2は、TCPサーバーに接続し、RabbitMQから受信したメッセージをこのサーバーに送信します。私の質問は、このメッセージを消費するサービス2が何らかのエラー（主にSocketExceptionがサーバーに接

0熱

1答えて

Spring Ampqタイプ名とEasyNetQ

C# MicroServicesとEasyNetQ、JavaとSpring Amqpの間でメッセージを送信する必要があります。問題はプロパティメッセージで、SpringブートからのタイプAmqpはプロパティ__type__ヘッダーコンテナにあり、EasynetQではtypeという外部プロパティから予想されます。誰も私もcomunicateにするためにカスタマイズする必要があることを教えてもらえ

1熱

1答えて

EasyNetQを使用して複数のRabbitMQキューを購読する

私はC＃/ .NETのRabbitMQでトピックベースルーティングの概念証明を行っています（EasyNetQライブラリを使用）。私のテストでは、トピックルーティング（ "TopicA"と "TopicB"）によって2つの耐久性のあるキューにバインドされた単一のエクスチェンジがあります。ここ生産（C＃のコンソールアプリケーション）のためのコードである：ここ using (var bus = Rab

1熱

1答えて

Easynetq：開発者のキュー

最近、publish-subscribeとrequest-responseの方法と共通キューの接続/エンドポイントにeasynetqキューを設定しました。目標は、キューを使用する開発ロジックが開発者間で独立していなければならないということです。現在、すべての開発者マシンが独自のプレフィックスキューセットを取得するようにコンフィグレーションしていますが、2人以上の開発者が所有キューおよび他の開発者キ

0熱

1答えて

既存のRabbitMQキューに排他的に接続する

私は、rabbitmqの既存のキューに加入しているワーカーがいます。冗長性のために、同じキューに接続する別のワーカーを追加することにしました。第1ワーカーがキューとの排他接続を取得して、第2ワーカーがメッセージをデキューできず、スタンバイワーカーとして機能するように設定できますか？