From 09b07db256997dc652084351e35e7f6a2b788d24 Mon Sep 17 00:00:00 2001 From: hsestupin Date: Tue, 13 Oct 2015 15:35:20 +0300 Subject: [PATCH] sending message to RemoteActor from the same node doesn't work --- .../remote/galaxy/GlxNonGlobalRemoteActor.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/quasar-galaxy/src/main/java/co/paralleluniverse/remote/galaxy/GlxNonGlobalRemoteActor.java b/quasar-galaxy/src/main/java/co/paralleluniverse/remote/galaxy/GlxNonGlobalRemoteActor.java index 634528b84b..05aa4c716f 100644 --- a/quasar-galaxy/src/main/java/co/paralleluniverse/remote/galaxy/GlxNonGlobalRemoteActor.java +++ b/quasar-galaxy/src/main/java/co/paralleluniverse/remote/galaxy/GlxNonGlobalRemoteActor.java @@ -86,7 +86,8 @@ public boolean shouldForwardMessage(Object msg) { } private boolean isNodeAlive() { - return grid.cluster().getNodes().contains(getOwnerNodeId()); + final short ownerNodeId = getOwnerNodeId(); + return grid.cluster().getMyNodeId() == ownerNodeId || grid.cluster().getNodes().contains(ownerNodeId); } @Override