rebus

1熱

1答えて

RabbitMQにメッセージを送信するとき、どういうふうに、以下のような余分なオブジェクトデータ、主に$タイプを追加しているのでしょうか。 {"$type":"ThreeSquared.VTGPAM.Objects.Wagon, ThreeSquared.VTGPAM.Objects","WagonId":"a98a06ab-33b9-4a11-9de2-df0b8787b713","WamosI

1熱

1答えて

Rebus RabbitMQを購読することができません

私はRabbitMQを使ってメッセージキューに正常に公開したメッセージを取得しようとしています。私がやっていないことは何をする必要があります。以下はサンプルコードですか？ static async Task MainSubscribeAsync() { var connection = "amqp://jhgj67546:[email protected]";

1熱

1答えて

Rebus RabbitMqサブスクリプションとアイテムの取得ができません

キューにオブジェクトを追加するとオブジェクトを取得できません。オブジェクトを追加するコードは次のとおりです。メッセージは次のように表示されます。待ち行列。 var connection = "amqp://name:[email protected]"; using (var activator = new BuiltinHandlerActivator()) { Configure

1熱

3答えて

REBUS変更を壊す

シナリオ：複数の衛星ライブラリにの.NET Framework 4.6 シンプルインジェクターを使用してのWeb APIアプリケーションREBUS Rebus.AzureServiceBus REBUS .SimpleInjector 私のアプリケーションには、複数の衛星ライブラリがあり、そのほとんどがSimpleInjector IPackageインタフェースを実装するクラスを持っています

1熱

1答えて

トランスポートRabbitMQでRebusを使用する場合のリモートプロシージャコールの典型的な実装は何ですか？

RPCの便利な実装はここにあります：https://github.com/gaevoy/Gaev.Rpc/tree/master/Gaev.Rpc.Rebus。この実装には多くの欠点があります。たとえば、クライアントが数百人になると、有用な応答の1％未満が受信され、サーバーは必要以上に何百倍も多くのデータを送信します。トランスポートRabbitMQでRebusを使用する場合のリモートプロシージ

2熱

1答えて

サブスクライバを一時停止する

サブスクライバを無効にする/有効にする必要があります。メッセージは送信できるという考えがありますが、サブスクライバがオフになっている場合、キュー内のメッセージは処理されません。再度オンにすると、キュー内のメッセージの処理が開始されます。私はpub/subとrequest/replyの例を見ているだけでなく、この質問に答える機能を探すためにRebusのソースコードを引っ張ってきました。 Defer

1熱

1答えて

Rabbitmqを使用したRebusの第2レベルの再試行

私はハンドラの1つでapiを呼び出し、Apiは月に6時間かかる可能性があるというシナリオがあります。したがって、1秒のリトライ、1分のリトライ、6時間のリトライでリトライロジックを設計しました。これはすべて正常に動作しますが、その後、長い遅延の再試行が良い選択肢ではないことがわかりました。これについて私にあなたの経験を教えてください。ありがとうございました！

3熱

1答えて

AzureサービスバスでRebusでパブリッシュ/サブスクライブを処理する

私はRebusを検討しており、Azure Service Busで使用しています。 Regalure Queuesでそれを使用するのは簡単でしたが、代わりにTopicを使用したい場合は、動作させることができません。セットアップが完了してトピック/サブスクリプションで使用されているものはありますか。これはこれまで私が持っていたものです。 static void Main(string[] arg

1熱

1答えて

Q：REBUS

でのルーティングの設定を拡張するためにどのように私は多くのWeb APIプロジェクトそこで、基本的のために共有されているREBUSコンフィグプロジェクトを持って、それは次のようになります Web APIを1 ==>共有REBUSコンフィグ Web APIを2 ==>共有REBUSコンフィグ Web APIを3 ==>共有REBUSコンフィグ私の質問は、私がWeb APIの3プロジェクトで&ハン

1熱

1答えて

Rebusでカスタムリトライメッセージのキューを設定する

SQL Serverを遅延メッセージストレージとして使用してカスタムリトライポリシーを作成できました。しかし今、スケーラビリティの理由から、私は複数のワーカー（メッセージハンドラタスク）を異なるマシンに展開して実行したいと考えています。その理由のために、私はSQL Serverから読み込むのではなく、待ち行列のような遅延メッセージを読む中心的な場所を持っていたいと思っています。遅延メッセージをキ