diff --git a/CommandsService/AsyncDataServices/MessageBusSubscriber.cs b/CommandsService/AsyncDataServices/MessageBusSubscriber.cs index 9cde0b2..fac041e 100644 --- a/CommandsService/AsyncDataServices/MessageBusSubscriber.cs +++ b/CommandsService/AsyncDataServices/MessageBusSubscriber.cs @@ -42,7 +42,7 @@ private void InitializeRabbitMQ() Console.WriteLine("--> Listenting on the Message Bus..."); - _connection.ConnectionShutdown += RabbitMQ_ConnectionShitdown; + _connection.ConnectionShutdown += RabbitMQ_ConnectionShutdown; } protected override Task ExecuteAsync(CancellationToken stoppingToken) @@ -66,7 +66,7 @@ protected override Task ExecuteAsync(CancellationToken stoppingToken) return Task.CompletedTask; } - private void RabbitMQ_ConnectionShitdown(object sender, ShutdownEventArgs e) + private void RabbitMQ_ConnectionShutdown(object sender, ShutdownEventArgs e) { Console.WriteLine("--> Connection Shutdown"); } @@ -82,4 +82,4 @@ public override void Dispose() base.Dispose(); } } -} \ No newline at end of file +} diff --git a/CommandsService/EventProcessing/EventProcessor.cs b/CommandsService/EventProcessing/EventProcessor.cs index e0dcb5a..a27ad76 100644 --- a/CommandsService/EventProcessing/EventProcessor.cs +++ b/CommandsService/EventProcessing/EventProcessor.cs @@ -69,7 +69,7 @@ private void addPlatform(string platformPublishedMessage) } else { - Console.WriteLine("--> Platform already exisits..."); + Console.WriteLine("--> Platform already exists..."); } } @@ -86,4 +86,4 @@ enum EventType PlatformPublished, Undetermined } -} \ No newline at end of file +} diff --git a/K8S/platforms-depl.yaml b/K8S/platforms-depl.yaml index bc3a213..59553b0 100644 --- a/K8S/platforms-depl.yaml +++ b/K8S/platforms-depl.yaml @@ -29,7 +29,7 @@ spec: protocol: TCP port: 80 targetPort: 80 - - name: plafromgrpc + - name: platformgrpc protocol: TCP port: 666 - targetPort: 666 \ No newline at end of file + targetPort: 666