How to publish message without waiting for response RabbitMQ

Question

I'm new to RabbitMq and I just followed internet resource as a tutorial. here I have created two separate API for OrderRequest and OrderConsume. from the order request, I'm calling something like this.

IRequestClient<OrderRequest> _client;
public OrderRepo(IRequestClient<OrderRequest> requestClient)
{
    _client = requestClient;
}

public async Task<string> GetOrderList(OrderRequest orderRequest)
{
    string datas = "";
    try
    {
        using (var request = _client.Create(orderRequest))
        {
            var response = await request.GetResponse<OrderReponse>();
            datas = response.Message.orderName;
        }
    }
    catch (Exception ex)
    {
        Console.WriteLine(ex.Message);
        throw;
    }
    return datas;
}

and from the OrderConsume, I did something like this.

public class OrderConsumer : IConsumer<OrderRequest>
{
    public Task Consume(ConsumeContext<OrderRequest> context)
    {
        OrderReponse request = new();
        try
        {
            var data = context.Message.orderName + " HelloWorld";
            request.orderName = data;
            
        }
        catch (System.Exception ex)
        {
            System.Console.WriteLine(ex.Message);
            throw;
        }
        return Task.CompletedTask;
    }
}

When I debugging the code Consume part working fine, but here you can see, I'm not passing any response from there. there for from the request API. I'm getting time out error.

Timeout waiting for response, RequestId: a1670000-a53b-c025-bd0b-08d9d52ca58a.

Actually I don't need any response from Consumer side, and just wanted to pass the request to consumer. I think I need to change my code here?

using (var request = _client.Create(orderRequest))
{
    var response = await request.GetResponse<OrderReponse>();
    datas = response.Message.orderName;
}

is it correct? but actually i don't know how to do it. please help me to solve this.

Chris Patterson · Accepted Answer · 2022-01-11 18:26:39Z

2

If your order command does not require a response, don't use the request client. Just publish the command and forget about it.

IPublishEndpoint _publishEndpoint;
public OrderRepo(IPublishEndpoint publishEndpoint)
{
    _publishEndpoint = publishEndpoint;
}

public async Task<string> GetOrderList(OrderRequest orderRequest)
{
    string datas = "";
    try
    {
        await _publishEndpoint.Publish<OrderRequest>(orderRequest);
    }
    catch (Exception ex)
    {
        Console.WriteLine(ex.Message);
        throw;
    }
    return datas;
}

Of course, in your original code you were actually using the response, so...

answered Jan 11, 2022 at 18:26

Chris Patterson

34.1k4 gold badges58 silver badges74 bronze badges

Sign up to request clarification or add additional context in comments.

1 Comment

Gamma Over a year ago

Hello sir, can you please check this and help me please, stackoverflow.com/questions/70947157/…

Collectives™ on Stack Overflow

How to publish message without waiting for response RabbitMQ

1 Answer 1

1 Comment

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

1 Comment

Your Answer

Sign up or log in

Post as a guest

Linked

Related