From f5b8b184b682115bd8fc07206cebf632d1771730 Mon Sep 17 00:00:00 2001 From: Halil ibrahim Kalkan Date: Tue, 18 Dec 2018 10:17:42 +0300 Subject: [PATCH] Add spaces between messages --- samples/RabbitMqEventBus/App1/App1MessagingService.cs | 1 - samples/RabbitMqEventBus/App1/App1TextEventHandler.cs | 1 + samples/RabbitMqEventBus/App1/App1TextReceivedEventHandler.cs | 3 ++- samples/RabbitMqEventBus/App2/App2MessagingService.cs | 1 - samples/RabbitMqEventBus/App2/App2TextEventHandler.cs | 1 + samples/RabbitMqEventBus/App2/App2TextReceivedEventHandler.cs | 3 ++- 6 files changed, 6 insertions(+), 4 deletions(-) diff --git a/samples/RabbitMqEventBus/App1/App1MessagingService.cs b/samples/RabbitMqEventBus/App1/App1MessagingService.cs index 89f2bab336..b8123d84d4 100644 --- a/samples/RabbitMqEventBus/App1/App1MessagingService.cs +++ b/samples/RabbitMqEventBus/App1/App1MessagingService.cs @@ -25,7 +25,6 @@ namespace App1 do { Console.WriteLine(); - Console.WriteLine("Send message to App2: "); message = Console.ReadLine(); diff --git a/samples/RabbitMqEventBus/App1/App1TextEventHandler.cs b/samples/RabbitMqEventBus/App1/App1TextEventHandler.cs index 48add1d986..046eda56b1 100644 --- a/samples/RabbitMqEventBus/App1/App1TextEventHandler.cs +++ b/samples/RabbitMqEventBus/App1/App1TextEventHandler.cs @@ -23,6 +23,7 @@ namespace App1 Console.WriteLine("************************ INCOMING MESSAGE ****************************"); Console.WriteLine(eventData.TextMessage); Console.WriteLine("**********************************************************************"); + Console.WriteLine(); _distributedEventBus.PublishAsync(new App1TextReceivedEventData(eventData.TextMessage)); diff --git a/samples/RabbitMqEventBus/App1/App1TextReceivedEventHandler.cs b/samples/RabbitMqEventBus/App1/App1TextReceivedEventHandler.cs index 2e0d22df5a..f9d6525e49 100644 --- a/samples/RabbitMqEventBus/App1/App1TextReceivedEventHandler.cs +++ b/samples/RabbitMqEventBus/App1/App1TextReceivedEventHandler.cs @@ -14,7 +14,8 @@ namespace App1 public Task HandleEventAsync(App2TextReceivedEventData eventData) { Console.WriteLine("--------> App2 has received the message: " + eventData.ReceivedText.TruncateWithPostfix(32)); - + Console.WriteLine(); + return Task.CompletedTask; } } diff --git a/samples/RabbitMqEventBus/App2/App2MessagingService.cs b/samples/RabbitMqEventBus/App2/App2MessagingService.cs index 22157342f2..b89e9dd960 100644 --- a/samples/RabbitMqEventBus/App2/App2MessagingService.cs +++ b/samples/RabbitMqEventBus/App2/App2MessagingService.cs @@ -25,7 +25,6 @@ namespace App2 do { Console.WriteLine(); - Console.WriteLine("Send message to App1: "); message = Console.ReadLine(); diff --git a/samples/RabbitMqEventBus/App2/App2TextEventHandler.cs b/samples/RabbitMqEventBus/App2/App2TextEventHandler.cs index ac26dd187b..8cf9ef65ae 100644 --- a/samples/RabbitMqEventBus/App2/App2TextEventHandler.cs +++ b/samples/RabbitMqEventBus/App2/App2TextEventHandler.cs @@ -23,6 +23,7 @@ namespace App2 Console.WriteLine("************************ INCOMING MESSAGE ****************************"); Console.WriteLine(eventData.TextMessage); Console.WriteLine("**********************************************************************"); + Console.WriteLine(); _distributedEventBus.PublishAsync(new App2TextReceivedEventData(eventData.TextMessage)); diff --git a/samples/RabbitMqEventBus/App2/App2TextReceivedEventHandler.cs b/samples/RabbitMqEventBus/App2/App2TextReceivedEventHandler.cs index fde68aa615..d53bac48b4 100644 --- a/samples/RabbitMqEventBus/App2/App2TextReceivedEventHandler.cs +++ b/samples/RabbitMqEventBus/App2/App2TextReceivedEventHandler.cs @@ -14,7 +14,8 @@ namespace App2 public Task HandleEventAsync(App1TextReceivedEventData eventData) { Console.WriteLine("--------> App1 has received the message: " + eventData.ReceivedText.TruncateWithPostfix(32)); - + Console.WriteLine(); + return Task.CompletedTask; } }