Fix #183 properly

strapdata · May 12, 2018 · 8ffee9e · 8ffee9e
1 parent b879987
commit 8ffee9e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/main/java/org/elassandra/discovery/CassandraDiscovery.java b/core/src/main/java/org/elassandra/discovery/CassandraDiscovery.java
@@ -521,9 +521,9 @@ private boolean isMember(InetAddress endpoint) {
      * ES RPC adress can be different from the cassandra broadcast address.
      */
     private boolean isNormal(DiscoveryNode node) {
-        EndpointState state = Gossiper.instance.getEndpointStateForEndpoint(InetAddresses.forString(node.getName()));
+        EndpointState state = Gossiper.instance.getEndpointStateForEndpoint(node.getInetAddress());
         if (state == null) {
-            logger.warn("Node name=[{}] address=[{}] state not found", node.getName(), node.getInetAddress());
+            logger.warn("Node endpoint address=[{}] name=[{}] state not found", node.getInetAddress(), node.getName());
             return false;
         }
         return state.isAlive() && state.getStatus().equals(VersionedValue.STATUS_NORMAL);