Line data    Source code

       1             : using System;
       2             : using Akka.Actor;
       3             : using Cqrs.Akka.Domain;
       4             : using Cqrs.Commands;
       5             : 
       6             : namespace Cqrs.Akka.Tests.Unit.Commands.Handlers
       7             : {
       8             :         public class UpdateCompletedConversationReportCommandHandler
       9             :                 : ICommandHandler<Guid, UpdateCompletedConversationReportCommand>
      10           0 :         {
      11             :                 /// <summary>
      12             :                 /// Instantiates the <see cref="SayHelloWorldCommandHandler"/> class registering any <see cref="ReceiveActor.Receive{T}(System.Func{T,System.Threading.Tasks.Task})"/> required.
      13             :                 /// </summary>
      14           1 :                 public UpdateCompletedConversationReportCommandHandler(IAkkaAggregateResolver aggregateResolver)
      15             :                 {
      16             :                         AggregateResolver = aggregateResolver;
      17             :                 }
      18             : 
      19             :                 protected IAkkaAggregateResolver AggregateResolver { get; private set; }
      20             : 
      21             :                 #region Implementation of IMessageHandler<in UpdateCompletedConversationReportCommand>
      22             : 
      23           0 :                 public void Handle(UpdateCompletedConversationReportCommand command)
      24             :                 {
      25             :                         AkkaUnitTests.FinalCommandReached[command.CorrelationId] = true;
      26             :                 }
      27             : 
      28             :                 #endregion
      29             :         }
      30             : }