From d2e0dfa8317e6b41d00f55928c8c72968cbd4aca Mon Sep 17 00:00:00 2001 From: Glenn Renfro Date: Thu, 13 Apr 2017 17:38:38 -0400 Subject: [PATCH] Updated BatchEventsAppTest to add groups --- .../test/java/io/spring/cloud/BatchEventsApplicationTests.java | 2 +- .../spring/task/listener/job-listener-sink-channel.properties | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/spring-cloud-task-samples/batch-events/src/test/java/io/spring/cloud/BatchEventsApplicationTests.java b/spring-cloud-task-samples/batch-events/src/test/java/io/spring/cloud/BatchEventsApplicationTests.java index 17f04d0b..e6b43160 100644 --- a/spring-cloud-task-samples/batch-events/src/test/java/io/spring/cloud/BatchEventsApplicationTests.java +++ b/spring-cloud-task-samples/batch-events/src/test/java/io/spring/cloud/BatchEventsApplicationTests.java @@ -48,7 +48,7 @@ public class BatchEventsApplicationTests { @Test public void testExecution() throws Exception { - SpringApplication.run(BatchEventsApplication.class, "--server.port=0"); + SpringApplication.run(BatchEventsApplication.class, "--server.port=0", "--spring.cloud.stream.bindings.output.producer.requiredGroups=testgroup"); Assert.assertTrue("The latch did not count down to zero before timeout", jobExecutionLatch.await(60, TimeUnit.SECONDS)); } diff --git a/spring-cloud-task-samples/batch-events/src/test/resources/io/spring/task/listener/job-listener-sink-channel.properties b/spring-cloud-task-samples/batch-events/src/test/resources/io/spring/task/listener/job-listener-sink-channel.properties index 0e98a419..8921774b 100644 --- a/spring-cloud-task-samples/batch-events/src/test/resources/io/spring/task/listener/job-listener-sink-channel.properties +++ b/spring-cloud-task-samples/batch-events/src/test/resources/io/spring/task/listener/job-listener-sink-channel.properties @@ -15,3 +15,4 @@ # spring.cloud.stream.bindings.input.destination=job-execution-events +spring.cloud.stream.bindings.input.group=testgroup