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

Use random port in StreamListenerTests

Browse Source
This commit is contained in:
Ilayaperumal Gopinathan
2016-05-13 11:38:15 +05:30
parent 33500ae183
commit bcc45b8685
1 changed files with 11 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/config/StreamListenerTests.java
View File

@@ -62,7 +62,7 @@ public class StreamListenerTests {
@Test
public void testContentTypeConversion() throws Exception {
ConfigurableApplicationContext context = SpringApplication.run(TestSink.class);
ConfigurableApplicationContext context = SpringApplication.run(TestSink.class, "--server.port=0");
@SuppressWarnings("unchecked")
TestSink testSink = context.getBean(TestSink.class);
Sink sink = context.getBean(Sink.class);
@@ -80,7 +80,7 @@ public class StreamListenerTests {
@SuppressWarnings("unchecked")
public void testAnnotatedArguments() throws Exception {
ConfigurableApplicationContext context = SpringApplication
.run(TestPojoWithAnnotatedArguments.class);
.run(TestPojoWithAnnotatedArguments.class, "--server.port=0");
TestPojoWithAnnotatedArguments testPojoWithAnnotatedArguments = context
.getBean(TestPojoWithAnnotatedArguments.class);
@@ -112,7 +112,7 @@ public class StreamListenerTests {
@SuppressWarnings("unchecked")
public void testReturn() throws Exception {
ConfigurableApplicationContext context = SpringApplication
.run(TestStringProcessor.class);
.run(TestStringProcessor.class, "--server.port=0");
MessageCollector collector = context.getBean(MessageCollector.class);
Processor processor = context.getBean(Processor.class);
String id = UUID.randomUUID().toString();
@@ -136,7 +136,8 @@ public class StreamListenerTests {
public void testReturnConversion() throws Exception {
ConfigurableApplicationContext context = SpringApplication.run(
TestPojoWithMimeType.class,
"--spring.cloud.stream.bindings.output.contentType=application/json");
"--spring.cloud.stream.bindings.output.contentType=application/json",
"--server.port=0");
MessageCollector collector = context.getBean(MessageCollector.class);
Processor processor = context.getBean(Processor.class);
String id = UUID.randomUUID().toString();
@@ -161,7 +162,7 @@ public class StreamListenerTests {
@SuppressWarnings("unchecked")
public void testReturnNoConversion() throws Exception {
ConfigurableApplicationContext context = SpringApplication
.run(TestPojoWithMimeType.class);
.run(TestPojoWithMimeType.class, "--server.port=0");
MessageCollector collector = context.getBean(MessageCollector.class);
Processor processor = context.getBean(Processor.class);
String id = UUID.randomUUID().toString();
@@ -184,7 +185,7 @@ public class StreamListenerTests {
@SuppressWarnings("unchecked")
public void testReturnMessage() throws Exception {
ConfigurableApplicationContext context = SpringApplication
.run(TestPojoWithMessageReturn.class);
.run(TestPojoWithMessageReturn.class, "--server.port=0");
MessageCollector collector = context.getBean(MessageCollector.class);
Processor processor = context.getBean(Processor.class);
String id = UUID.randomUUID().toString();
@@ -207,7 +208,7 @@ public class StreamListenerTests {
@SuppressWarnings("unchecked")
public void testMessageArgument() throws Exception {
ConfigurableApplicationContext context = SpringApplication
.run(TestPojoWithMessageArgument.class);
.run(TestPojoWithMessageArgument.class, "--server.port=0");
MessageCollector collector = context.getBean(MessageCollector.class);
Processor processor = context.getBean(Processor.class);
String id = UUID.randomUUID().toString();
@@ -230,7 +231,7 @@ public class StreamListenerTests {
public void testDuplicateMapping() throws Exception {
try {
ConfigurableApplicationContext context = SpringApplication
.run(TestDuplicateMapping.class);
.run(TestDuplicateMapping.class, "--server.port=0");
fail("Exception expected on duplicate mapping");
}
catch (BeanCreationException e) {
@@ -244,7 +245,8 @@ public class StreamListenerTests {
public void testHandlerBean() throws Exception {
ConfigurableApplicationContext context = SpringApplication.run(
TestHandlerBean.class,
"--spring.cloud.stream.bindings.output.contentType=application/json");
"--spring.cloud.stream.bindings.output.contentType=application/json",
"--server.port=0");
MessageCollector collector = context.getBean(MessageCollector.class);
Processor processor = context.getBean(Processor.class);
String id = UUID.randomUUID().toString();