Add RequestMessageException.

SaladLab · May 29, 2016 · b61e19f · b61e19f
1 parent 40cedd4
commit b61e19f
Show file tree

Hide file tree

Showing 3 changed files with 19 additions and 4 deletions.
diff --git a/core/Akka.Interfaced-Base/Exceptions.cs b/core/Akka.Interfaced-Base/Exceptions.cs
@@ -17,6 +17,21 @@ protected AkkaInterfacedException(string message, Exception innerException = nul
         }
     }
 
+    /// <summary>
+    /// This exception is thrown when a request message has something wrong.
+    /// </summary>
+    public class RequestMessageException : AkkaInterfacedException
+    {
+        public RequestMessageException()
+        {
+        }
+
+        public RequestMessageException(string message, Exception innerException = null)
+            : base(message, innerException)
+        {
+        }
+    }
+
     /// <summary>
     /// This exception is thrown when the actor which have a request is not found.
     /// </summary>

diff --git a/core/Akka.Interfaced/InterfacedActor.cs b/core/Akka.Interfaced/InterfacedActor.cs
@@ -205,7 +205,7 @@ private void OnRequestMessage(RequestMessage request)
                 sender.Tell(new ResponseMessage
                 {
                     RequestId = request.RequestId,
-                    Exception = new InvalidMessageException("Empty payload")
+                    Exception = new RequestMessageException("Empty payload")
                 });
                 return;
             }
@@ -216,7 +216,7 @@ private void OnRequestMessage(RequestMessage request)
                 sender.Tell(new ResponseMessage
                 {
                     RequestId = request.RequestId,
-                    Exception = new InvalidMessageException("Cannot find handler")
+                    Exception = new RequestMessageException("Cannot find handler")
                 });
                 return;
             }

diff --git a/plugins/Akka.Interfaced.Persistence/InterfacedPersistentActor.cs b/plugins/Akka.Interfaced.Persistence/InterfacedPersistentActor.cs
@@ -220,7 +220,7 @@ private void OnRequestMessage(RequestMessage request)
                 sender.Tell(new ResponseMessage
                 {
                     RequestId = request.RequestId,
-                    Exception = new InvalidMessageException("Empty payload")
+                    Exception = new RequestMessageException("Empty payload")
                 });
                 return;
             }
@@ -231,7 +231,7 @@ private void OnRequestMessage(RequestMessage request)
                 sender.Tell(new ResponseMessage
                 {
                     RequestId = request.RequestId,
-                    Exception = new InvalidMessageException("Cannot find handler")
+                    Exception = new RequestMessageException("Cannot find handler")
                 });
                 return;
             }