Fixed FakeActor bug: didn't call filterMessage in internalSendNonSusp…

…endable
puniverse · Jan 21, 2014 · e382589 · e382589
1 parent 3519d2b
commit e382589
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/quasar-actors/src/main/java/co/paralleluniverse/actors/FakeActor.java b/quasar-actors/src/main/java/co/paralleluniverse/actors/FakeActor.java
@@ -86,7 +86,11 @@ protected void internalSend(Object message) throws SuspendExecution {
 
     @Override
     protected void internalSendNonSuspendable(Object message) {
-        if (!mailbox().trySend(message))
+        record(1, "ActorRef", "internalSendNonSuspendable", "Sending %s -> %s", message, this);
+        Message msg = filterMessage(message);
+        if (msg == null)
+            return;
+        if (!mailbox().trySend(msg))
             throw new QueueCapacityExceededException();
     }