For Each object in List, create a producer and consumer in rabbitmq using C#

[danammeansbear]

basically I am wanting to create and destroy queues and consumers dynamically at runtime based on the sensor list. I have added code that only works sorta. I am hoping someone with more experience can help me figure out how to do what I want to do with a bunch of sensors and agents monitoring the sensors. Am I looking at rabbitMQ wrong? how would I be able to monitor multiple sensors?

  public class SensorQueueConsumer
    {
        public static void Consume(IModel channel)
        {
            Tasks.AddData();
            foreach (string sensor in Sensor.SensorList)
            {

                channel.QueueDeclare($"{sensor}Queue",
            durable: true,
            exclusive: false,
            autoDelete: false,
            arguments: null);
                var consumer = new EventingBasicConsumer(channel);
                consumer.Received += (sender, e) =>
                {
                    var body = e.Body.ToArray();
                    var message = Encoding.UTF8.GetString(body);
                    Console.WriteLine(message);
                };

                channel.BasicConsume($"{sensor}Queue", true, consumer);
                Console.WriteLine("consumer started");
                Console.ReadLine();
            }
        }
    }

and

 public static class SensorQueueProducer
    {
        public static void Publish(IModel channel)
        {Tasks.AddData();
            foreach (string sensor in Sensor.SensorList)
            {
                channel.QueueDeclare($"{sensor}Queue",
            durable: true,
            exclusive: false,
            autoDelete: false,
            arguments: null);
                var Count = 0;
                while (true)
                {
                    var message = new { Name = "PlantEvent", Sensor = sensor, Saverity = "high", Message = $"Hello! Water me!! Count:{Count}" };
                    var body = Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(message));

                    channel.BasicPublish("", $"{sensor}Queue", null, body);
                    Count++;
                    Thread.Sleep(1000);
                }

            }
        }
    }

and also the sensor class the list

public class Sensor
    {
        public static List<String> SensorList { get; set; } = new List<String>();

    }
    public class Tasks
    {
        public static void AddData()
        {
            string[] sensors = { "ec", "soil", "co2" };
            Sensor.SensorList.AddRange(sensors);

        }

        public static void ClearData()
        {
            Sensor.SensorList.Clear();
        }
    }

[michaelklishin]

Two methods of interest are channel.BasicConsume (which returns a consumer identifier, a consumer tag) and channel.BasicCancel that cancel a consumer using its tag. You can call them at arbitrary moments.

These only operate on consumers, not queues. You have have to declare and delete queues dynamically as well depending on what your goal and desired topology are.

Publishing transient messages in a tight loop is a great way to run your node out of resources, in particular of RAM.