antonyvorontsov / RabbitMQ.Client.Core.DependencyInjection

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

Consuming from queue when Exchange to Exchange binding set #100

Open gzres opened 2 years ago

gzres commented 2 years ago

I have such situation: Message are passed to FirstExchange with some.routing.key FirstExchange binds some.routing.key to SecondExchange exchange SecondExchange binds some.routing.key to queue MyQueue.

Using code

var rabbitMqSection = hostContext.Configuration.GetSection("RabbitMq");
var exchangeSection = hostContext.Configuration.GetSection("RabbitMqExchange");

services.AddRabbitMqServices(rabbitMqSection)
                .AddConsumptionExchange("SecondExchange", exchangeSection)
                .AddMessageHandlerTransient<MyMessageHandler>("some.routing.key");

messages from MyQueue are on Unacked state but nothing happens in MyMessageHandler logs in Console are empty. When I shutdown worker messages return to queue with Ready state.

How to start processing messages from MyQueue inMyMessageHandler?

Im using version 5 of library. Thanks for help.