masstransit

    7

    3答えて

    MassTransitで単純なパブリッシャー/コンシューマーセットを実装しましたが、コンシューマーに同じキューからメッセージを読み込ませたいと思います。しかし、私はそれを実行すると、メッセージの大部分が消費されるのではなく、エラーキューに送られるのがわかります。私が見たディスカッション(SO、Forum)から、これはRabbitMQ(同じキューを指している)で本当に簡単なはずですが、動作しません。

    6

    2答えて

    私はエラーキューを処理することなく、再試行制限を超えた直後に、失敗したメッセージをログする良い解決策を探しています。私がこれまでに見つけた何を:私はInMemoryInboundMessageTrackerから継承してオーバーライドすることができます をIsRetryLimitExceededが、そこにこの時点IDを除くメッセージそのものについての情報はありませんで。 私はIInboundMess

    9

    1答えて

    で を動作させるために必要な消費者のキューである私はMassTransitとRabbitMQのまわりで私の頭を取得しようとキューイングしています(1日目) 私が持っている疑問は、「消費者が必要であるかどうかであります私が最初にDomainとProducerを作ったが、私はRabbitMQ管理ウィンドウで待ち行列に入ったアイテムを見なかったからです。 コンシューマキューが作成されると、メッセージがキ

    23

    1答えて

    MassTransitの上に構築する利点は、RabbitMQの上に直接的に建物に比べて何ですか? MassTransitが提供するメリットの1つは、メッセージの内容が構造化されていないtext/blobであるプレーンなRabbitMQ交換と比較して、メッセージの内容が構造化されるように 'タイプ'交換(インターフェイス/タイプによる購読) MassTransitでは他にどのようなメリットがあります

    6

    1答えて

    私はMassTransitを見て、メッセージを扱うクラスを書いています。 Consumes<T>からインターフェイスを実装すると、4つのオプションが得られます:All、Selected、For<T>、Context四人の違いは何ですか?いつそれらを使うべきですか?

    11

    2答えて

    私はRabbitMQバージョン3.0.2を使用しています&エラーキューには1000個近くのメッセージがあります。私は知りたい どの時点でメッセージがエラーキューに移動しますか? 特定のメッセージがエラーキューに移動している理由を知る方法はありますか? メッセージをエラーキューから通常キューに移動する方法はありますか? あなたは、キュー内のメッセージで覗いたら... そうでもないというメッセージを5

    7

    1答えて

    私のアプリケーションのボトルネックは、MassTransitを使用してMSMQでメッセージを送受信しています。送信と受信の両方が同じアプリケーション内で起こっていますが、メモリ内のキューを使用するにはメッセージが多すぎます。ここで は私の単純なキューの設定です:私の実験のために messageBus = ServiceBusFactory.New(sbc => {

    2

    1答えて

    私のMassTransit sagaには、正しくマップされないフィールドが1つしかありません。それはある -私はそれをカップルの方法をマッピングしようとした public virtual IDictionary<string, string> Rows { get { return _rows; } set { _rows = value; } }

    1

    1答えて

    私は単純な例でMassTransitで遊んでいますが、正しいデータを受け取っていないので、間違っていることはわかりません。 は、私はこのコードをデバッグする場合、私はTweetCreatedCommandが公開されてどのように見ることができます public class TweetCreatedCommand : Command { public readonly string Mes

    16

    1答えて

    これはおそらく非常に簡単な答えですが、私はMassTransitのドキュメントやフォーラムで明らかな解決策を見ていません。 RabbitMQのエラーキューに移動したメッセージがある場合、それらを処理キューに戻すための最良のメカニズムは何ですか?また、最初にそこに移動した理由の組み込みログがありますか?