From c7e4320999be89ff8a00758e3afcbf49770ed324 Mon Sep 17 00:00:00 2001 From: David Webb Date: Mon, 26 Jan 2015 11:33:42 -0500 Subject: [PATCH] DATACASS-197: Reconsider usage of ingestions for general CQL test cases Task-Url: https://jira.spring.io/browse/DATACASS-197 --- .../integration/core/template/async/AsynchronousTest.java | 2 +- .../test/integration/core/template/async/ListListener.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/spring-cql/src/test/java/org/springframework/cassandra/test/integration/core/template/async/AsynchronousTest.java b/spring-cql/src/test/java/org/springframework/cassandra/test/integration/core/template/async/AsynchronousTest.java index b4bb403cf..a5c820c63 100644 --- a/spring-cql/src/test/java/org/springframework/cassandra/test/integration/core/template/async/AsynchronousTest.java +++ b/spring-cql/src/test/java/org/springframework/cassandra/test/integration/core/template/async/AsynchronousTest.java @@ -15,8 +15,8 @@ import java.util.concurrent.CancellationException; import org.junit.Before; import org.junit.Test; import org.springframework.cassandra.core.AsynchronousQueryListener; -import org.springframework.cassandra.core.ConsistencyLevel; import org.springframework.cassandra.core.Cancellable; +import org.springframework.cassandra.core.ConsistencyLevel; import org.springframework.cassandra.core.QueryForListOfMapListener; import org.springframework.cassandra.core.QueryForMapListener; import org.springframework.cassandra.core.QueryForObjectListener; diff --git a/spring-cql/src/test/java/org/springframework/cassandra/test/integration/core/template/async/ListListener.java b/spring-cql/src/test/java/org/springframework/cassandra/test/integration/core/template/async/ListListener.java index 074036bb2..1b1060da8 100644 --- a/spring-cql/src/test/java/org/springframework/cassandra/test/integration/core/template/async/ListListener.java +++ b/spring-cql/src/test/java/org/springframework/cassandra/test/integration/core/template/async/ListListener.java @@ -12,13 +12,13 @@ public class ListListener extends TestListener implements QueryForListListene @Override public void onQueryComplete(List results) { - countDown(); this.result = results; + countDown(); } @Override public void onException(Exception x) { - countDown(); this.exception = x; + countDown(); } }