antonyvorontsov / RabbitMQ.Client.Core.DependencyInjection

.Net Core library-wrapper of RabbitMQ.Client for Dependency Injection.
MIT License
111 stars 36 forks source link

How to RequeueFailedMessage ? #94

Closed iwaitu closed 2 years ago

iwaitu commented 2 years ago

appsettings.json

 "RabbitMq": {
    "HostName": "localhost",
    "Port": "32030",
    "UserName": "user",
    "Password": "userpassword"
  },
  "RabbitMqExchange": {
    "Type": "direct",
    "Durable": true,
    "AutoDelete": false,
    "DeadLetterExchange": "OrderSystem.exchange",
    "RequeueFailedMessages": true,
    "Queues": [
      {
        "Name": "OrderSystem",
        "RoutingKeys": [ "CCBNotice" ]
      }
    ]
  },
public async Task Handle(BasicDeliverEventArgs eventArgs, string matchingRoute)
 {
            var content = Encoding.UTF8.GetString(eventArgs.Body.ToArray());
            var message = JsonConvert.DeserializeObject<NoticeMessage>(content);
            throw new Exception("test retry");
}

I try to throw e exception in Handle method, but the message do not be requeue , anything wrong in the code ?