diff --git a/src/test/java/org/springframework/data/gemfire/listener/ListenerContainerTests.java b/src/test/java/org/springframework/data/gemfire/listener/ListenerContainerTests.java index 6cacf031..5344de04 100644 --- a/src/test/java/org/springframework/data/gemfire/listener/ListenerContainerTests.java +++ b/src/test/java/org/springframework/data/gemfire/listener/ListenerContainerTests.java @@ -16,9 +16,9 @@ package org.springframework.data.gemfire.listener; +import java.util.ArrayList; +import java.util.List; import java.util.Properties; -import java.util.concurrent.BlockingDeque; -import java.util.concurrent.LinkedBlockingDeque; import org.junit.AfterClass; import org.junit.Before; @@ -37,7 +37,7 @@ import com.gemstone.gemfire.cache.query.CqEvent; */ public class ListenerContainerTests { - private final BlockingDeque bag = new LinkedBlockingDeque(); + private final List bag = new ArrayList(); protected ContinuousQueryListenerContainer container; private static RegionService cache = null; diff --git a/src/test/java/org/springframework/data/gemfire/listener/StubErrorHandler.java b/src/test/java/org/springframework/data/gemfire/listener/StubErrorHandler.java index 6d2454cf..7aad6baf 100644 --- a/src/test/java/org/springframework/data/gemfire/listener/StubErrorHandler.java +++ b/src/test/java/org/springframework/data/gemfire/listener/StubErrorHandler.java @@ -15,8 +15,8 @@ */ package org.springframework.data.gemfire.listener; -import java.util.concurrent.BlockingDeque; -import java.util.concurrent.LinkedBlockingDeque; +import java.util.ArrayList; +import java.util.List; import org.springframework.util.ErrorHandler; @@ -25,7 +25,7 @@ import org.springframework.util.ErrorHandler; */ public class StubErrorHandler implements ErrorHandler { - public BlockingDeque throwables = new LinkedBlockingDeque(); + public List throwables = new ArrayList(); public void handleError(Throwable t) {