fix: bug fixes in consumers/producers templating

components/Consumers.js

@@ -1,7 +1,13 @@
+import { toPascalCase } from '../utils/common';
+
 export function Consumers({ channels }) {
   if (channels?.length == 0) {
     return null;
   }
 
-  return `_amqpService.OnSensorTemperatureChange();`;
+  return `protected override Task ExecuteAsync(CancellationToken stoppingToken)
+        {
+          _amqpService.${toPascalCase(channels[0].operationId)}();
+          return Task.CompletedTask;
+        }`;
 }

components/Publishers.js

@@ -1,19 +1,19 @@
+import { toPascalCase } from '../utils/common';
+
 export function Publishers({ channels }) {
   if (channels?.length == 0) {
     return null;
   }
-  return `var rnd = new Random((int) DateTime.Now.Ticks);
+
+  return `protected override async Task ExecuteAsync(CancellationToken stoppingToken)
+        {
+            // TODO: Send message on custom events, below is a timing example. 
+            var rnd = new Random((int) DateTime.Now.Ticks);
             while (!stoppingToken.IsCancellationRequested)
             {
-                var t = new Temperature
-                {
-                    Celcius = rnd.Next(-25, 120),
-                    Created = $"{DateTimeOffset.Now:yyyy-MM-dd HH:mm:ss}",
-                    Origin = "SENSOR-001"
-                };
-
-                _amqpService.OnSpecificSensorTemperatureReceived(t);
-                
+                var message = new ${toPascalCase(channels[0].messageType)}();
+                _amqpService.${toPascalCase(channels[0].operationId)}(message);
                 await Task.Delay(rnd.Next(500, 3000), stoppingToken);
-            }`;
+            }
+        }`;
 }

components/Worker.js

@@ -23,11 +23,8 @@ namespace ${params.namespace}
             _amqpService = new AmqpService(configuration);
         }
 
-        protected override async Task ExecuteAsync(CancellationToken stoppingToken)
-        {
-            ${childrenContent}
-        }
-
+        ${childrenContent}
+        
         public override void Dispose()
         {
             base.Dispose();

components/templates/amqpservice.js

@@ -126,12 +126,23 @@ public class AmqpService : IAmqpService
           consumer.operationId
         )}");
 
+        // TODO: declare passive?
+        channel.QueueDeclare(queue);
+
+        channel.QueueBind(queue: queue,
+                  exchange: "${consumer.exchange}",
+                  routingKey: "${consumer.routingKey}");
+
         var consumer = new EventingBasicConsumer(channel);
         consumer.Received += (_, ea) =>
         {
             var body = ea.Body.ToArray();
-            var temperature = JsonSerializer.Deserialize<Temperature>(Encoding.UTF8.GetString(body));
-            _logger.Verbose("Temperature received, {@Temperature}", temperature);
+            var message = JsonSerializer.Deserialize<${
+              consumer.messageType
+            }>(Encoding.UTF8.GetString(body));
+            _logger.Verbose("${toPascalCase(
+              consumer.messageType
+            )} received, {@${toPascalCase(consumer.messageType)}}", message);
 
             try
             {
@@ -141,7 +152,9 @@ public class AmqpService : IAmqpService
             }
             catch (Exception e)
             {
-                _logger.Error(e, "Something went wrong trying to process message {@Temperature},", temperature);
+                _logger.Error(e, "Something went wrong trying to process message {@${toPascalCase(
+                  consumer.messageType
+                )}},", message);
                 channel.BasicReject(ea.DeliveryTag, false);
             }
         };