diff --git a/data/src/main/java/com/ericsson/bss/cassandra/ecchronos/data/sync/EccNodesSync.java b/data/src/main/java/com/ericsson/bss/cassandra/ecchronos/data/sync/EccNodesSync.java index 56fb25058..389b3ed71 100644 --- a/data/src/main/java/com/ericsson/bss/cassandra/ecchronos/data/sync/EccNodesSync.java +++ b/data/src/main/java/com/ericsson/bss/cassandra/ecchronos/data/sync/EccNodesSync.java @@ -19,7 +19,6 @@ import com.datastax.oss.driver.api.core.cql.PreparedStatement; import com.datastax.oss.driver.api.core.cql.BoundStatement; import com.datastax.oss.driver.api.core.cql.ResultSet; -import com.datastax.oss.driver.api.core.cql.Row; import com.datastax.oss.driver.api.core.metadata.Node; import com.datastax.oss.driver.api.querybuilder.QueryBuilder; import com.datastax.oss.driver.shaded.guava.common.annotations.VisibleForTesting; @@ -30,9 +29,7 @@ import java.net.UnknownHostException; import java.time.Instant; import java.time.temporal.ChronoUnit; -import java.util.ArrayList; import java.util.List; -import java.util.Objects; import java.util.UUID; import org.slf4j.Logger; diff --git a/data/src/test/java/com/ericsson/bss/cassandra/ecchronos/data/sync/TestEccNodesSync.java b/data/src/test/java/com/ericsson/bss/cassandra/ecchronos/data/sync/TestEccNodesSync.java index 8781cbc30..865cb387d 100644 --- a/data/src/test/java/com/ericsson/bss/cassandra/ecchronos/data/sync/TestEccNodesSync.java +++ b/data/src/test/java/com/ericsson/bss/cassandra/ecchronos/data/sync/TestEccNodesSync.java @@ -25,7 +25,6 @@ import net.jcip.annotations.NotThreadSafe; import org.junit.After; import org.junit.Before; -import org.junit.Ignore; import org.junit.Test; import java.net.UnknownHostException; @@ -147,18 +146,11 @@ public void testEccNodesWithNullSession() assertEquals("Session cannot be null", exception.getMessage()); } - @Ignore @Test - public void testGetUnavailableNodes() + public void testGetAllNodes() { - // Setup test data in the table with mixed statuses - // Insert some nodes with AVAILABLE status eccNodesSync.verifyInsertNodeInfo(datacenterName, "127.0.0.1", NodeStatus.AVAILABLE.name(), Instant.now(), Instant.now().plus(30, ChronoUnit.MINUTES), UUID.randomUUID()); - - // Insert some nodes with other statuses eccNodesSync.verifyInsertNodeInfo(datacenterName, "127.0.0.2", NodeStatus.UNAVAILABLE.name(), Instant.now(), Instant.now().plus(30, ChronoUnit.MINUTES), UUID.randomUUID()); - - // Call the method ResultSet resultSet = eccNodesSync.getResultSet(); assertNotNull(resultSet); }