From 978d5e630a68a40ca1e1cf92436fb77cc3604143 Mon Sep 17 00:00:00 2001 From: Jose Carvajal Date: Fri, 1 Dec 2017 08:48:36 +0100 Subject: [PATCH] BAEL-1174: A Quick Guide to Spring Cloud Consul --- ...ipleOutputsServiceApplicationUnitTest.java | 52 ------------------- ...eOutputsWithConditionsServiceUnitTest.java | 52 ------------------- .../rabbit/MyLoggerApplicationUnitTest.java | 40 -------------- undertow/dependency-reduced-pom.xml | 1 + 4 files changed, 1 insertion(+), 144 deletions(-) delete mode 100644 spring-cloud/spring-cloud-stream/spring-cloud-stream-rabbit/src/test/java/com/baeldung/spring/cloud/stream/rabbit/MultipleOutputsServiceApplicationUnitTest.java delete mode 100644 spring-cloud/spring-cloud-stream/spring-cloud-stream-rabbit/src/test/java/com/baeldung/spring/cloud/stream/rabbit/MultipleOutputsWithConditionsServiceUnitTest.java delete mode 100644 spring-cloud/spring-cloud-stream/spring-cloud-stream-rabbit/src/test/java/com/baeldung/spring/cloud/stream/rabbit/MyLoggerApplicationUnitTest.java diff --git a/spring-cloud/spring-cloud-stream/spring-cloud-stream-rabbit/src/test/java/com/baeldung/spring/cloud/stream/rabbit/MultipleOutputsServiceApplicationUnitTest.java b/spring-cloud/spring-cloud-stream/spring-cloud-stream-rabbit/src/test/java/com/baeldung/spring/cloud/stream/rabbit/MultipleOutputsServiceApplicationUnitTest.java deleted file mode 100644 index 225ed73ff7..0000000000 --- a/spring-cloud/spring-cloud-stream/spring-cloud-stream-rabbit/src/test/java/com/baeldung/spring/cloud/stream/rabbit/MultipleOutputsServiceApplicationUnitTest.java +++ /dev/null @@ -1,52 +0,0 @@ -package com.baeldung.spring.cloud.stream.rabbit; - -import static org.junit.Assert.assertEquals; - -import org.junit.Test; -import org.junit.runner.RunWith; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.cloud.stream.test.binder.MessageCollector; -import org.springframework.messaging.MessageChannel; -import org.springframework.messaging.support.MessageBuilder; -import org.springframework.test.annotation.DirtiesContext; -import org.springframework.test.context.ContextConfiguration; -import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; - -import com.baeldung.spring.cloud.stream.rabbit.processor.MyProcessor; - -@RunWith(SpringJUnit4ClassRunner.class) -@ContextConfiguration(classes = MultipleOutputsServiceApplication.class) -@DirtiesContext -public class MultipleOutputsServiceApplicationUnitTest { - - @Autowired - private MyProcessor pipe; - - @Autowired - private MessageCollector messageCollector; - - @Test - public void whenSendMessage_thenResponseIsInAOutput() { - whenSendMessage(1); - thenPayloadInChannelIs(pipe.anOutput(), 1); - } - - @Test - public void whenSendMessage_thenResponseIsInAnotherOutput() { - whenSendMessage(11); - thenPayloadInChannelIs(pipe.anotherOutput(), 11); - } - - private void whenSendMessage(Integer val) { - pipe.myInput() - .send(MessageBuilder.withPayload(val) - .build()); - } - - private void thenPayloadInChannelIs(MessageChannel channel, Integer expectedValue) { - Object payload = messageCollector.forChannel(channel) - .poll() - .getPayload(); - assertEquals(expectedValue, payload); - } -} diff --git a/spring-cloud/spring-cloud-stream/spring-cloud-stream-rabbit/src/test/java/com/baeldung/spring/cloud/stream/rabbit/MultipleOutputsWithConditionsServiceUnitTest.java b/spring-cloud/spring-cloud-stream/spring-cloud-stream-rabbit/src/test/java/com/baeldung/spring/cloud/stream/rabbit/MultipleOutputsWithConditionsServiceUnitTest.java deleted file mode 100644 index 8628b209cb..0000000000 --- a/spring-cloud/spring-cloud-stream/spring-cloud-stream-rabbit/src/test/java/com/baeldung/spring/cloud/stream/rabbit/MultipleOutputsWithConditionsServiceUnitTest.java +++ /dev/null @@ -1,52 +0,0 @@ -package com.baeldung.spring.cloud.stream.rabbit; - -import static org.junit.Assert.assertEquals; - -import org.junit.Test; -import org.junit.runner.RunWith; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.cloud.stream.test.binder.MessageCollector; -import org.springframework.messaging.MessageChannel; -import org.springframework.messaging.support.MessageBuilder; -import org.springframework.test.annotation.DirtiesContext; -import org.springframework.test.context.ContextConfiguration; -import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; - -import com.baeldung.spring.cloud.stream.rabbit.processor.MyProcessor; - -@RunWith(SpringJUnit4ClassRunner.class) -@ContextConfiguration(classes = MultipleOutputsWithConditionsServiceApplication.class) -@DirtiesContext -public class MultipleOutputsWithConditionsServiceUnitTest { - - @Autowired - private MyProcessor pipe; - - @Autowired - private MessageCollector messageCollector; - - @Test - public void whenSendMessage_thenResponseIsInAOutput() { - whenSendMessage(1); - thenPayloadInChannelIs(pipe.anOutput(), 1); - } - - @Test - public void whenSendMessage_thenResponseIsInAnotherOutput() { - whenSendMessage(11); - thenPayloadInChannelIs(pipe.anotherOutput(), 11); - } - - private void whenSendMessage(Integer val) { - pipe.myInput() - .send(MessageBuilder.withPayload(val) - .build()); - } - - private void thenPayloadInChannelIs(MessageChannel channel, Integer expectedValue) { - Object payload = messageCollector.forChannel(channel) - .poll() - .getPayload(); - assertEquals(expectedValue, payload); - } -} diff --git a/spring-cloud/spring-cloud-stream/spring-cloud-stream-rabbit/src/test/java/com/baeldung/spring/cloud/stream/rabbit/MyLoggerApplicationUnitTest.java b/spring-cloud/spring-cloud-stream/spring-cloud-stream-rabbit/src/test/java/com/baeldung/spring/cloud/stream/rabbit/MyLoggerApplicationUnitTest.java deleted file mode 100644 index 1541af3cb5..0000000000 --- a/spring-cloud/spring-cloud-stream/spring-cloud-stream-rabbit/src/test/java/com/baeldung/spring/cloud/stream/rabbit/MyLoggerApplicationUnitTest.java +++ /dev/null @@ -1,40 +0,0 @@ -package com.baeldung.spring.cloud.stream.rabbit; - -import static org.junit.Assert.assertEquals; - -import org.junit.Test; -import org.junit.runner.RunWith; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.cloud.stream.messaging.Processor; -import org.springframework.cloud.stream.test.binder.MessageCollector; -import org.springframework.messaging.support.MessageBuilder; -import org.springframework.test.annotation.DirtiesContext; -import org.springframework.test.context.ContextConfiguration; -import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; - -import com.baeldung.spring.cloud.stream.rabbit.model.LogMessage; - -@RunWith(SpringJUnit4ClassRunner.class) -@ContextConfiguration(classes = MyLoggerServiceApplication.class) -@DirtiesContext -public class MyLoggerApplicationUnitTest { - - @Autowired - private Processor pipe; - - @Autowired - private MessageCollector messageCollector; - - @Test - public void whenSendMessage_thenResponseShouldUpdateText() { - pipe.input() - .send(MessageBuilder.withPayload(new LogMessage("This is my message")) - .build()); - - Object payload = messageCollector.forChannel(pipe.output()) - .poll() - .getPayload(); - - assertEquals("[1]: This is my message", payload.toString()); - } -} diff --git a/undertow/dependency-reduced-pom.xml b/undertow/dependency-reduced-pom.xml index e8fcd39fbb..0654c82b74 100644 --- a/undertow/dependency-reduced-pom.xml +++ b/undertow/dependency-reduced-pom.xml @@ -37,3 +37,4 @@ 1.8 +