Browse Source

Add spaces between messages

pull/666/head
Halil ibrahim Kalkan 8 years ago
parent
commit
f5b8b184b6
  1. 1
      samples/RabbitMqEventBus/App1/App1MessagingService.cs
  2. 1
      samples/RabbitMqEventBus/App1/App1TextEventHandler.cs
  3. 3
      samples/RabbitMqEventBus/App1/App1TextReceivedEventHandler.cs
  4. 1
      samples/RabbitMqEventBus/App2/App2MessagingService.cs
  5. 1
      samples/RabbitMqEventBus/App2/App2TextEventHandler.cs
  6. 3
      samples/RabbitMqEventBus/App2/App2TextReceivedEventHandler.cs

1
samples/RabbitMqEventBus/App1/App1MessagingService.cs

@ -25,7 +25,6 @@ namespace App1
do do
{ {
Console.WriteLine(); Console.WriteLine();
Console.WriteLine("Send message to App2: ");
message = Console.ReadLine(); message = Console.ReadLine();

1
samples/RabbitMqEventBus/App1/App1TextEventHandler.cs

@ -23,6 +23,7 @@ namespace App1
Console.WriteLine("************************ INCOMING MESSAGE ****************************"); Console.WriteLine("************************ INCOMING MESSAGE ****************************");
Console.WriteLine(eventData.TextMessage); Console.WriteLine(eventData.TextMessage);
Console.WriteLine("**********************************************************************"); Console.WriteLine("**********************************************************************");
Console.WriteLine();
_distributedEventBus.PublishAsync(new App1TextReceivedEventData(eventData.TextMessage)); _distributedEventBus.PublishAsync(new App1TextReceivedEventData(eventData.TextMessage));

3
samples/RabbitMqEventBus/App1/App1TextReceivedEventHandler.cs

@ -14,7 +14,8 @@ namespace App1
public Task HandleEventAsync(App2TextReceivedEventData eventData) public Task HandleEventAsync(App2TextReceivedEventData eventData)
{ {
Console.WriteLine("--------> App2 has received the message: " + eventData.ReceivedText.TruncateWithPostfix(32)); Console.WriteLine("--------> App2 has received the message: " + eventData.ReceivedText.TruncateWithPostfix(32));
Console.WriteLine();
return Task.CompletedTask; return Task.CompletedTask;
} }
} }

1
samples/RabbitMqEventBus/App2/App2MessagingService.cs

@ -25,7 +25,6 @@ namespace App2
do do
{ {
Console.WriteLine(); Console.WriteLine();
Console.WriteLine("Send message to App1: ");
message = Console.ReadLine(); message = Console.ReadLine();

1
samples/RabbitMqEventBus/App2/App2TextEventHandler.cs

@ -23,6 +23,7 @@ namespace App2
Console.WriteLine("************************ INCOMING MESSAGE ****************************"); Console.WriteLine("************************ INCOMING MESSAGE ****************************");
Console.WriteLine(eventData.TextMessage); Console.WriteLine(eventData.TextMessage);
Console.WriteLine("**********************************************************************"); Console.WriteLine("**********************************************************************");
Console.WriteLine();
_distributedEventBus.PublishAsync(new App2TextReceivedEventData(eventData.TextMessage)); _distributedEventBus.PublishAsync(new App2TextReceivedEventData(eventData.TextMessage));

3
samples/RabbitMqEventBus/App2/App2TextReceivedEventHandler.cs

@ -14,7 +14,8 @@ namespace App2
public Task HandleEventAsync(App1TextReceivedEventData eventData) public Task HandleEventAsync(App1TextReceivedEventData eventData)
{ {
Console.WriteLine("--------> App1 has received the message: " + eventData.ReceivedText.TruncateWithPostfix(32)); Console.WriteLine("--------> App1 has received the message: " + eventData.ReceivedText.TruncateWithPostfix(32));
Console.WriteLine();
return Task.CompletedTask; return Task.CompletedTask;
} }
} }

Loading…
Cancel
Save