Send Message with IRequestReplyClient throwing Producer not started exception

[juanmacrod]

Hi everyone,
I'm using IRequestReplyClient to send a message to artemis in .net core 8 using the directions for DI.
However, I'm getting a Producer not started exception when I try to send a message.
I have tried registering an AnonymousProducer with DI but I'm not sure where I should be using it.

Here is an excerpt from startup:
services.AddActiveMq("artemis", endpoints).AddRequestReplyClient<OTRequestReplyClient>().AddAnonymousProducer<MessageProducer>(); services.AddActiveMqHostedService();
In my RequestReplyClient:
var response = await rrClient.SendAsync(address, msg, cancellationToken); => throws Producer not started exception

Could someone please point me in the right direction?

Many Thanks for any help.

[Havret]

Hi @juanmacrod,

You don’t need to register additional producers to use the RequestReplyClient. The AddRequestReplyClient method is sufficient. To start the producer (and the consumer) used by the RequestReplyClient, you need to resolve the IActiveMqClient from your service provider and call StartAsync. Similarly, ensure you call StopAsync for a graceful shutdown. This is handled automatically if you’re using AddActiveMqHostedService.

If the issue persists, consider providing a minimal reproducible example or a unit test so I can help investigate further.

Thanks,
Havret

[Havret]

Hi, Please take a look at this example: https://havret.github.io/dotnet-activemq-artemis-client/docs/request-reply. The key issue seems to be that you're not sending a response back to the `ReplyTo` address. You need to acknowledge the incoming message and then send the response to the specified `ReplyTo` address. Everything you need is in the documentation, but if you need further clarification, feel free to ask. I hope this helps! Havret

…

On Sun, Nov 24, 2024 at 12:14 PM juanmacrod ***@***.***> wrote: Hi @Havret <https://github.com/Havret>, Thanks for the quick reply. The exception was caused because I think the consumer was not running - at least, I don't see it anymore. Unfortunately, when sending the message the process just hangs and doesn't seem to call the consumer on the other service. Here is my consumer startup: `` services.AddActiveMq("artemis", endpoints) .AddConsumer("OT_REQUEST", ActiveMQ.Artemis.Client.RoutingType.Anycast, async (message, consumer, serviceProvider, CancelllationToken) => { var request = JsonSerializer.Deserialize(message.GetBody()); Console.WriteLine("Request received: " + request); var responseMessage = new ActiveMQ.Artemis.Client.Message(JsonSerializer.Serialize("Response to: " + request)) { CorrelationId = message.CorrelationId }; await consumer.AcceptAsync(responseMessage, null); Console.WriteLine("Response sent: " + responseMessage.GetBody<string>()); }); services.AddActiveMqHostedService(); `` They should both be sending/receiving on the queue OT-REQUEST but somethings seems not quite right with my queues: image.png (view on web) <https://github.com/user-attachments/assets/425b7b91-caa2-4478-a8ab-f8decad44a87> The message in the OT-REQUEST queue has a reply-to of the temp queue ......63e which has a consumer bound. Am I doing something fundamentally wrong? — Reply to this email directly, view it on GitHub <#512 (comment)>, or unsubscribe <https://github.com/notifications/unsubscribe-auth/ACFOT5MDZ34GCEINCPBRX5L2CGYI7AVCNFSM6AAAAABSLAIIKOVHI2DSMVQWIX3LMV43URDJONRXK43TNFXW4Q3PNVWWK3TUHMYTCMZWGI2TENA> . You are receiving this because you were mentioned.Message ID: <Havret/dotnet-activemq-artemis-client/repo-discussions/512/comments/11362524 @github.com>

[juanmacrod]

Hi,
Many thanks for you quick response and your patience
I have tried it this way but I think I am doing something fundamentally wrong.
Here an excerpt of my code:

Request
startup
Here I initialise the RequestReplyClient
services.AddActiveMq("artemis",` endpoints).AddRequestReplyClient<OTRequestReplyClient>(); services.AddActiveMqHostedService();
controller
in the controller I send the message
var response = await rrClient.SendAsync(address, msg, cancellationToken);
``

Response
startup
Here I initialise the Consumer and message handler
services.AddActiveMq("artemis", endpoints) .AddConsumer("OT-REQUEST", ActiveMQ.Artemis.Client.RoutingType.Anycast, async (message, consumer, serviceProvider, cancelllationToken) => { await OrderTrackingListRequestConsumer.HandleMessage("OT-REQUEST", endpoints[0], message, consumer, serviceProvider, cancelllationToken); }); services.AddActiveMqHostedService();
message handler
The message handler is called when there is a new Message
var connectionFactory = new ActiveMQ.Artemis.Client.ConnectionFactory(); var connection = await connectionFactory.CreateAsync(endpoint); var request = await consumer.ReceiveAsync(); await using var producer = await connection.CreateAnonymousProducerAsync(); await producer.SendAsync(request.ReplyTo, new ActiveMQ.Artemis.Client.Message("test") { CorrelationId = request.CorrelationId, TimeToLive = TimeSpan.FromSeconds(30) }); await consumer.AcceptAsync(request);

Sometimes it works correctly.
What happens ca. 90% of the time, I send a message and then the consumer message handler is called but it hangs at
await consumer.ReceiveAsync();

Any help would be greatly appreciated.
Thanks for your time.
Juan

[juanmacrod]

Hi,
my mistake!!!
I was calling consumer.ReceiveAsync without needing it because the message handler already had a reference to the incoming message.
With that call removed, It's working fine now.
Many Thanks for such a great project.