Merge pull request #38 from sopra-steria-norge/dotnet-2-eventdriven-oppsett

Fasit / oppsett av basic consumer & producer

Author: larsklingenberg

2-EventDriven/dotnet-consumer/Consumer/Program.cs

@@ -16,4 +16,31 @@
 // - Create a channel
 // - Declare a queue
 // - Create a consumer and subscribe to the queue
-// - Handle incoming messages by deserializing the JSON and printing the content to the console
+// - Handle incoming messages by deserializing the JSON and printing the content to the console
+
+
+
+// Create a channel and declare the queue
+using var channel = await connection.CreateChannelAsync();
+await channel.QueueDeclareAsync(queue: "idem-events", durable: true, exclusive: false, autoDelete: false, arguments: null);
+
+// Set up a consumer to listen for messages
+var consumer = new AsyncEventingBasicConsumer(channel);
+
+// Handle received messages
+consumer.ReceivedAsync += async (sender, eventArgs) =>
+{
+    var body = eventArgs.Body.ToArray();
+    var message = JsonSerializer.Deserialize<JsonNode>(Encoding.UTF8.GetString(body));
+
+    Console.WriteLine($"Received message: {message}");
+
+    // Simulate processing time
+    await Task.Delay(1000);
+
+    // Acknowledge the message
+    await channel.BasicAckAsync(eventArgs.DeliveryTag, multiple: false);   
+};
+// Start consuming messages
+await channel.BasicConsumeAsync(queue: "idem-events", autoAck: false, consumerTag: "", noLocal: false, exclusive: false, arguments: null, consumer: consumer);
+Console.ReadLine(); // Keep the application running to listen for messages

2-EventDriven/dotnet-consumer/Producer/Program.cs

@@ -12,4 +12,25 @@
 // Start with:
 // - Create a channel
 // - Declare a queue
-// - Publish a message to the queue (you can use a simple JSON string as the message body)
+// - Publish a message to the queue (you can use a simple JSON string as the message body)
+
+
+// Create a channel and declare the queue
+using var channel = await connection.CreateChannelAsync();
+await channel.QueueDeclareAsync(queue: "idem-events", durable: true, exclusive: false, autoDelete: false, arguments: null);
+
+// Publish messages to the queue with for loop to simulate multiple events
+for (int i = 0; i < 10; i++)
+{
+    var message = $"Idems Event {i + 1} at {DateTime.Now}";
+
+    var messageBody = JsonSerializer.Serialize(message);
+    var body = Encoding.UTF8.GetBytes(messageBody);
+
+    await channel.BasicPublishAsync(exchange: string.Empty, routingKey: "idem-events", mandatory: true, basicProperties: new BasicProperties { Persistent = true }, body: body);
+    Console.WriteLine($"Published event: {message}");
+
+    await Task.Delay(2000);
+}
+
+Console.WriteLine("Producer finished.");