SpringCloud/spring-cloud-task
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Updated BatchEventsAppTest to add groups

Browse Source
This commit is contained in:
Glenn Renfro
2017-04-13 17:38:38 -04:00
parent db00cd76e3
commit d2e0dfa831
2 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-cloud-task-samples/batch-events/src/test/java/io/spring/cloud/BatchEventsApplicationTests.java
View File

@@ -48,7 +48,7 @@ public class BatchEventsApplicationTests {
@Test @Test
public void testExecution() throws Exception { 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", Assert.assertTrue("The latch did not count down to zero before timeout",
jobExecutionLatch.await(60, TimeUnit.SECONDS)); jobExecutionLatch.await(60, TimeUnit.SECONDS));
} }

1
spring-cloud-task-samples/batch-events/src/test/resources/io/spring/task/listener/job-listener-sink-channel.properties
View File

@@ -15,3 +15,4 @@
# #
spring.cloud.stream.bindings.input.destination=job-execution-events spring.cloud.stream.bindings.input.destination=job-execution-events
spring.cloud.stream.bindings.input.group=testgroup