Skip to content

Commit

Permalink
Add spaces between messages
Browse files Browse the repository at this point in the history
  • Loading branch information
hikalkan committed Dec 18, 2018
1 parent 40fa063 commit f5b8b18
Show file tree
Hide file tree
Showing 6 changed files with 6 additions and 4 deletions.
1 change: 0 additions & 1 deletion samples/RabbitMqEventBus/App1/App1MessagingService.cs
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,6 @@ public void Run()
do
{
Console.WriteLine();
Console.WriteLine("Send message to App2: ");

message = Console.ReadLine();

Expand Down
1 change: 1 addition & 0 deletions samples/RabbitMqEventBus/App1/App1TextEventHandler.cs
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@ public Task HandleEventAsync(App2ToApp1TextEventData eventData)
Console.WriteLine("************************ INCOMING MESSAGE ****************************");
Console.WriteLine(eventData.TextMessage);
Console.WriteLine("**********************************************************************");
Console.WriteLine();

_distributedEventBus.PublishAsync(new App1TextReceivedEventData(eventData.TextMessage));

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,8 @@ public class App1TextReceivedEventHandler : IDistributedEventHandler<App2TextRec
public Task HandleEventAsync(App2TextReceivedEventData eventData)
{
Console.WriteLine("--------> App2 has received the message: " + eventData.ReceivedText.TruncateWithPostfix(32));

Console.WriteLine();

return Task.CompletedTask;
}
}
Expand Down
1 change: 0 additions & 1 deletion samples/RabbitMqEventBus/App2/App2MessagingService.cs
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,6 @@ public void Run()
do
{
Console.WriteLine();
Console.WriteLine("Send message to App1: ");

message = Console.ReadLine();

Expand Down
1 change: 1 addition & 0 deletions samples/RabbitMqEventBus/App2/App2TextEventHandler.cs
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@ public Task HandleEventAsync(App1ToApp2TextEventData eventData)
Console.WriteLine("************************ INCOMING MESSAGE ****************************");
Console.WriteLine(eventData.TextMessage);
Console.WriteLine("**********************************************************************");
Console.WriteLine();

_distributedEventBus.PublishAsync(new App2TextReceivedEventData(eventData.TextMessage));

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,8 @@ public class App2TextReceivedEventHandler : IDistributedEventHandler<App1TextRec
public Task HandleEventAsync(App1TextReceivedEventData eventData)
{
Console.WriteLine("--------> App1 has received the message: " + eventData.ReceivedText.TruncateWithPostfix(32));

Console.WriteLine();

return Task.CompletedTask;
}
}
Expand Down

0 comments on commit f5b8b18

Please sign in to comment.