diff --git a/spring-integration-gemfire/src/test/java/org/springframework/integration/gemfire/inbound/cq/client/CqClientConfiguration.java b/spring-integration-gemfire/src/test/java/org/springframework/integration/gemfire/inbound/cq/client/CqClientConfiguration.java index 7124a17acd..919f9dff26 100644 --- a/spring-integration-gemfire/src/test/java/org/springframework/integration/gemfire/inbound/cq/client/CqClientConfiguration.java +++ b/spring-integration-gemfire/src/test/java/org/springframework/integration/gemfire/inbound/cq/client/CqClientConfiguration.java @@ -89,7 +89,7 @@ public class CqClientConfiguration { @ServiceActivator public void handleMessage(Message eventMessage) throws MessagingException { CqEvent cqEvent = eventMessage.getPayload(); - log.info("Received an event from the continuous query adapter: " + cqEvent); + System.out.println("Received an event from the continuous query adapter: " + cqEvent) ; } }; } diff --git a/spring-integration-gemfire/src/test/java/org/springframework/integration/gemfire/store/messagegroupstore/GemfireMessageGroupStoreTest.java b/spring-integration-gemfire/src/test/java/org/springframework/integration/gemfire/store/messagegroupstore/GemfireMessageGroupStoreTest.java index adb90d2948..4b85af5e77 100644 --- a/spring-integration-gemfire/src/test/java/org/springframework/integration/gemfire/store/messagegroupstore/GemfireMessageGroupStoreTest.java +++ b/spring-integration-gemfire/src/test/java/org/springframework/integration/gemfire/store/messagegroupstore/GemfireMessageGroupStoreTest.java @@ -12,11 +12,14 @@ import java.util.List; import java.util.Set; /** - * Tests the Gemfire {@link org.springframework.integration.store.MessageGroupStore} implementation, {@link org.springframework.integration.gemfire.store.GemfireMessageGroupStore} + * Tests the Gemfire {@link org.springframework.integration.store.MessageGroupStore} implementation, + * {@link org.springframework.integration.gemfire.store.GemfireMessageGroupStore}. * + * It tests the {@link org.springframework.integration.store.MessageGroupStore} by sending 10 batches of letters (all of the same width), + * and then counting on the other end that indeed all 10 batches arrived and that all letters expected are there. + * * * @author Josh Long */ - @RunWith(SpringJUnit4ClassRunner.class) @ContextConfiguration(loader = AnnotationConfigContextLoader.class, classes = {GemfireMessageGroupStoreTestConfiguration.class}) public class GemfireMessageGroupStoreTest {