How can i call rabbitMq get message from asp.net Webapi?

Question

My question is simple. I wanna use rabbitmq to make message queue by using asp.net webapi. On the other hand, GetAllQueues not returning any message. Message is always null. Below code perfect in console application but message always null when i run below post :

http://localhost:53301/api/CustomerPipline/?queueName=test123


using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Web.Http;
using RabbitMQ.Client;
using System.Text;
using RabbitMQ.Client.Events;
using System.Diagnostics;
using RabbitMQ.Client.Exceptions;

namespace Atom.Mqpipline.Controllers
{
    public class CustomerPiplineController : ApiController
    {
        private static readonly string _queueName = "test123";


        [HttpPost]
        public HttpResponseMessage AddQueue(int customerId)
        {

           var  publisher = new Publisher(_queueName, "Hello RabbitMQ World!");
            var resp = Request.CreateResponse(HttpStatusCode.OK, JsonConvert.SerializeObject("OK"));

            return resp;
        }
        [HttpGet]
        public HttpResponseMessage GetAllQueues(string queueName)
        {
            var consumer = new Consumer(queueName);
            var resp = Request.CreateResponse(HttpStatusCode.OK, JsonConvert.SerializeObject(consumer.Message));
            return resp;
        }
    }

}

public class RabbitMQService
{
    private readonly string _hostName = "localhost";

    public IConnection GetRabbitMQConnection()
    {
        ConnectionFactory connectionFactory = new ConnectionFactory()
        {
            HostName = _hostName
        };

        return connectionFactory.CreateConnection();
    }
}
public class Publisher
{
    private readonly RabbitMQService _rabbitMQService;

    public Publisher(string queueName, string message)
    {
        _rabbitMQService = new RabbitMQService();

        using (var connection = _rabbitMQService.GetRabbitMQConnection())
        {
            using (var channel = connection.CreateModel())
            {
                channel.QueueDeclare(queueName, false, false, false, null);
                channel.BasicPublish("", queueName, null, Encoding.UTF8.GetBytes(message));
            }
        }
    }
}

public class Consumer
{
    private readonly RabbitMQService _rabbitMQService;
    public string Message { get; set; }
    public Consumer(string queueName)
    {

        _rabbitMQService = new RabbitMQService();

        using (var connection = _rabbitMQService.GetRabbitMQConnection())
        {
            using (var channel = connection.CreateModel())
            {
                var consumer = new EventingBasicConsumer(channel);
                // Received event'i sürekli listen modunda olacaktır.
                consumer.Received += (model, ea) =>
                {
                    var body = ea.Body;
                    var message = Encoding.UTF8.GetString(body);
                    Debug.WriteLine(message);
                    Message = message;
                };

                channel.BasicConsume(queueName, true, consumer);
            }
        }
    }
}

Guru Stron · Accepted Answer · 2021-06-29 13:45:57Z

2

you cannot call consumer. consumer action runs when received a message not when you call.

create only one instance of Consumer on your app..
add a queue received message. or push message direct to client via SignalR.

edited Jun 29, 2021 at 13:45

Guru Stron

151k11 gold badges186 silver badges232 bronze badges

answered Mar 3, 2017 at 11:10

levent

3,6541 gold badge16 silver badges22 bronze badges

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

1 Comment

Prageeth godage Over a year ago

can you please eleborate or give real ipmlementation "crete only one instance of Consumer on your app"

Dharman · Accepted Answer · 2021-06-29 13:41:29Z

1

I don't think you can consume message in a postback or a rest endpoint. But you can start a Task that receive the queue on the startup of your project.

        public void Configure(IApplicationBuilder app)
        {
            [...]
            Task.Run(GetAllQueues(queueName));
        }

        public void GetAllQueues(string queueName)
        {
            var consumer = new Consumer(queueName);
            var resp = Request.CreateResponse(HttpStatusCode.OK, JsonConvert.SerializeObject(consumer.Message));
            return resp;
        }

edited Jun 29, 2021 at 13:41

Dharman♦

33.9k27 gold badges106 silver badges157 bronze badges

answered Jun 29, 2021 at 13:35

Rogerio Gelonezi

3442 silver badges4 bronze badges

Collectives™ on Stack Overflow

How can i call rabbitMq get message from asp.net Webapi?

2 Answers 2

1 Comment

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

1 Comment

Comments

Your Answer

Sign up or log in

Post as a guest

Related