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

Question

メッセージをエラーキューから元のキューに戻そうとしています。 これを行うには、エラーキューにコンシューマを作成し、それを必要なキューに公開しました。 これを試してみると、Consumed Messagesの半分が公開されますが、残りの半分はError_Skipped Queueに送信されます。

私は多くのことを成功させずに試してきました。だから、おそらく私が紛失している単純なものです。

は、ここに私のコードのサンプルです：

public class ClaimsMessage 
{ 
    public string Description { get; set; } 

    public DateTime Date { get; set; } 

    public bool Handled { get; set; } 
} 

public class ClaimsMessageErrorConsumer : IConsumer<Fault<ClaimsMessage>> 
{ 
    public async Task Consume(ConsumeContext<Fault<ClaimsMessage>> context) 
    { 
     try 
     { 
      await context.Publish<ClaimsMessage>(context.Message.Message); 

     } 
     catch (Exception e) 
     { 
      string error = e.Message; 
     } 
    } 
} 

public static IBusControl CreateClaimsErrorConsumerBus(string endPoint) 
{ 
    var busControl = Bus.Factory.CreateUsingRabbitMq(cfg => 
    { 
     var host = cfg.Host(new Uri("rabbitmq://localhost/"), h => 
     { 
      h.Username("guest"); 
      h.Password("guest"); 
     }); 

     cfg.ReceiveEndpoint(host, endPoint, e => 
     { 
      e.Consumer(() => new ClaimsMessageErrorConsumer()); 
     }); 
    }); 
    return busControl; 
} 

Answer 1

あなたが戻って処理キューにエラー・キューからメッセージを移動する場合、あなたはPublishを呼ぶべきではない - これは、すべての加入者にメッセージを再送信します。すでにキュー名がわかっているので、メッセージを直接キューに戻してください。あなたが見ているのは、エラーキューにコンシューマを作成したことです。エラーキューには、そのメッセージの交換バインディングが作成されています。メッセージの忠実性が保持されるように、元のメッセージのヘッダーをコピーし、余分な信用のために

sbc.ReceiveEndpoint("input_error", x => 
{ 
    // this prevents extra message bindings from being created 
    x.BindMessageExchanges = false; 

    x.Consumer<MyMover>(() => new MyMover(inputQueueAddress); 
}); 

public class MyMover : 
    IConsumer<ClaimsMessage> 
{ 
    public async Task Consume(ConsumeContext<ClaimsMessage> context) 
    { 
     try 
     { 
      var endpoint = await context.GetSendEndpoint(_inputQueueAddress); 
      await endpoint.Send<ClaimsMessage>(context.Message); 
     } 
     catch (Exception e) 
     { 
      string error = e.Message; 
     } 
    } 
} 

：

ので、代わりにこれを行います。