Aaronontheweb on dev
cleaned up protobuf CLI and def… (compare)
Receive<RequestMessage>(e => ProcessRequest(e));
Receive<ResponseMessage>(p => SendResponseBack(p));
}
private void ProcessRequest(RequestMessage requestMessage)
{
Logger.Debug($"{Self.Path.Name} started request processing");
_aDependency.ProcessAsync(requestMessage.Data)
.ContinueWith(e => new ResponseMessage(e.Result), TaskContinuationOptions.AttachedToParent & TaskContinuationOptions.ExecuteSynchronously)
.PipeTo(Self, Context.Sender);
}
private void SendResponseBack(ResponseMessage response)
{
Context.Sender.Tell(response, Self);
Logger.Debug($"{Self.Path.Name} finished request processing");
}`