lundi 19 août 2019

How do I use the rabbitmq in my .net core web as a consumer

As the title suggests,Examples on the official website are console project but is it really impossible to apply to asp.net core web? My web project as a consumer but does not output received information,so What are consumers in the actual production environment? this is my code :

var factory = new ConnectionFactory()
        {
            UserName = "admin",
            Password = "admin",
            Port = 5672,
            HostName = "192.168.150.129",
            RequestedHeartbeat = 0,
            VirtualHost = "/vhost_mmr"
        };
        using (var connection = factory.CreateConnection())
        {
            using (var channel =connection.CreateModel())
            {
                var consumer = new EventingBasicConsumer(channel);
                 consumer.Received +=  (model, ea) =>
                {
                    var body = ea.Body;
                    var msg = Encoding.UTF8.GetString(body);
                    ViewBag.msg = msg;
                    System.Diagnostics.Debug.Write("test:" + msg);
                };

                var ret = channel.BasicConsume(queue: "hello",
                                     autoAck: true,
                                     consumer: consumer);
            }
        }




Aucun commentaire:

Enregistrer un commentaire