Line data    Source code

       1             : using System;
       2             : using Cqrs.Akka.Commands;
       3             : using Cqrs.Commands;
       4             : using Cqrs.Events;
       5             : 
       6             : namespace Cqrs.Akka.Tests.Unit.Events.Handlers
       7             : {
       8             :         public class ConversationEndedEventHandler
       9             :                 : IEventHandler<Guid, ConversationEnded>
      10           0 :         {
      11           0 :                 public ConversationEndedEventHandler(IAkkaCommandSender<Guid> commandBus)
      12             :                 {
      13             :                         CommandBus = commandBus;
      14             :                 }
      15             : 
      16             :                 protected ICommandPublisher<Guid> CommandBus { get; private set; }
      17             : 
      18             :                 #region Implementation of IMessageHandler<in ConversationEnded>
      19             : 
      20           0 :                 public void Handle(ConversationEnded message)
      21             :                 {
      22             :                         AkkaUnitTests.Step4Reached[message.CorrelationId] = true;
      23             :                 }
      24             : 
      25             :                 #endregion
      26             :         }
      27             : }