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

Added repositories to sample projects poms.

Browse Source 
Updated BatchApplicationEventTests to shorten wait timeout and remove unnecessary Ignore and OutputCapture
This commit is contained in:
Glenn Renfro
2017-04-14 09:00:01 -04:00
parent d2e0dfa831
commit 85573cf5ec
5 changed files with 152 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -21,13 +21,10 @@ import java.util.concurrent.TimeUnit;
import org.junit.Assert;
import org.junit.ClassRule;
import org.junit.Ignore;
import org.junit.Rule;
import org.junit.Test;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.test.rule.OutputCapture;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.binder.test.junit.rabbit.RabbitTestSupport;
@@ -40,9 +37,6 @@ public class BatchEventsApplicationTests {
@ClassRule
public static RabbitTestSupport rabbitTestSupport = new RabbitTestSupport();
@Rule
public OutputCapture outputCapture = new OutputCapture();
// Count for two job execution events per task
static CountDownLatch jobExecutionLatch = new CountDownLatch(2);
@@ -50,7 +44,7 @@ public class BatchEventsApplicationTests {
public void testExecution() throws Exception {
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));
jobExecutionLatch.await(5, TimeUnit.SECONDS));
}
@EnableBinding(Sink.class)