🐛 fix handling of admin messages in GlxGlobalRemoteActor

puniverse · Aug 27, 2015 · 6612b71 · 6612b71
1 parent 28736da
commit 6612b71
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/quasar-galaxy/src/main/java/co/paralleluniverse/remote/galaxy/GlxGlobalRemoteActor.java b/quasar-galaxy/src/main/java/co/paralleluniverse/remote/galaxy/GlxGlobalRemoteActor.java
@@ -33,7 +33,17 @@ private void startReceiver() {
         final ActorImpl<Message> actor = getActor();
         if (actor == null)
             throw new IllegalStateException("Actor for " + this + " not running locally");
-        GlobalRemoteChannelReceiver.getReceiver(actor.getMailbox(), id);
+        final GlobalRemoteChannelReceiver<Object> receiver = GlobalRemoteChannelReceiver.getReceiver(actor.getMailbox(), id);
+        receiver.setFilter(new GlobalRemoteChannelReceiver.MessageFilter<Object>() {
+            @Override
+            public boolean shouldForwardMessage(Object msg) {
+                if (msg instanceof RemoteActorAdminMessage) {
+                    handleAdminMessage((RemoteActorAdminMessage) msg);
+                    return false;
+                }
+                return true;
+            }
+        });
     }
 
     @Override