, Message>("a message that ") {
+ @Override
+ public Message
apply(Message
m) {
+ return m;
+ }
+ });
+ }
+
+ @SuppressWarnings("unchecked")
+ public static
MessageQueueMatcher
receivesPayloadThat(Matcher
payloadMatcher) {
+ return new MessageQueueMatcher(payloadMatcher, -1, null, new Extractor, P>("a message whose payload ") {
+ @Override
+ public P apply(Message m) {
+ return m.getPayload();
+ }
+ });
+ }
+
+ /**
+ * A transformation to be applied to a received message before asserting, e.g. to only inspect the payload.
+ */
+ public static abstract class Extractor implements Function, SelfDescribing {
+
+ private final String behaviorDescription;
+
+ protected Extractor(String behaviorDescription) {
+ this.behaviorDescription = behaviorDescription;
+ }
+
+ @Override
+ public void describeTo(Description description) {
+ description.appendText(behaviorDescription);
+ }
+ }
+
+
+
+}
diff --git a/spring-cloud-stream-test-support/src/main/resources/META-INF/spring.factories b/spring-cloud-stream-test-support/src/main/resources/META-INF/spring.factories
new file mode 100644
index 000000000..baa0d75ca
--- /dev/null
+++ b/spring-cloud-stream-test-support/src/main/resources/META-INF/spring.factories
@@ -0,0 +1,2 @@
+org.springframework.boot.autoconfigure.EnableAutoConfiguration:\
+org.springframework.cloud.stream.test.binder.TestSupportBinderAutoConfiguration
diff --git a/spring-cloud-stream-test-support/src/test/java/org/springframework/cloud/stream/test/ExampleTest.java b/spring-cloud-stream-test-support/src/test/java/org/springframework/cloud/stream/test/ExampleTest.java
new file mode 100644
index 000000000..af2ad41be
--- /dev/null
+++ b/spring-cloud-stream-test-support/src/test/java/org/springframework/cloud/stream/test/ExampleTest.java
@@ -0,0 +1,79 @@
+/*
+ * Copyright 2015 the original author or authors.
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.stream.test;
+
+import static org.hamcrest.CoreMatchers.*;
+import static org.junit.Assert.*;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.test.IntegrationTest;
+import org.springframework.boot.test.SpringApplicationConfiguration;
+import org.springframework.cloud.stream.annotation.EnableModule;
+import org.springframework.cloud.stream.annotation.ModuleChannels;
+import org.springframework.cloud.stream.annotation.Processor;
+import org.springframework.cloud.stream.test.binder.MessageCollector;
+import org.springframework.cloud.stream.test.binder.TestSupportBinder;
+import org.springframework.integration.annotation.Transformer;
+import org.springframework.messaging.Message;
+import org.springframework.messaging.support.GenericMessage;
+import org.springframework.test.annotation.DirtiesContext;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+/**
+ * Integration test that validates that {@link org.springframework.cloud.stream.test.binder.TestSupportBinder} applies
+ * correctly.
+ */
+@RunWith(SpringJUnit4ClassRunner.class)
+@SpringApplicationConfiguration(classes = ExampleTest.MyProcessor.class)
+@IntegrationTest({"server.port=-1"})
+@DirtiesContext
+public class ExampleTest {
+
+ @Autowired
+ @ModuleChannels(MyProcessor.class)
+ private Processor processor;
+
+ @Autowired
+ private MessageCollector messageCollector;
+
+ @Test
+ @SuppressWarnings("unchecked")
+ public void testWiring() {
+ Message message = new GenericMessage<>("hello");
+ processor.input().send(message);
+ Message received = (Message) messageCollector.forChannel(processor.output()).poll();
+ assertThat(received.getPayload(), equalTo("hello world"));
+ }
+
+
+ @SpringBootApplication
+ @EnableModule(Processor.class)
+ public static class MyProcessor {
+
+ @Autowired
+ private Processor channels;
+
+ @Transformer(inputChannel = Processor.INPUT, outputChannel = Processor.OUTPUT)
+ public String transform(String in) {
+ return in + " world";
+ }
+ }
+
+}
diff --git a/spring-cloud-stream-test-support/src/test/java/org/springframework/cloud/stream/test/matcher/MessageQueueMatcherTest.java b/spring-cloud-stream-test-support/src/test/java/org/springframework/cloud/stream/test/matcher/MessageQueueMatcherTest.java
new file mode 100644
index 000000000..7d056e5a3
--- /dev/null
+++ b/spring-cloud-stream-test-support/src/test/java/org/springframework/cloud/stream/test/matcher/MessageQueueMatcherTest.java
@@ -0,0 +1,113 @@
+/*
+ * Copyright 2015 the original author or authors.
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.stream.test.matcher;
+
+import static org.hamcrest.CoreMatchers.*;
+import static org.junit.Assert.*;
+
+import java.util.Collections;
+import java.util.concurrent.BlockingDeque;
+import java.util.concurrent.LinkedBlockingDeque;
+import java.util.concurrent.TimeUnit;
+
+import org.hamcrest.StringDescription;
+import org.junit.Test;
+
+import org.springframework.messaging.Message;
+import org.springframework.messaging.support.GenericMessage;
+
+/**
+ * Tests for MessageQueueMatcher.
+ *
+ * @author Eric Bottard
+ */
+public class MessageQueueMatcherTest {
+
+ private final BlockingDeque> queue = new LinkedBlockingDeque<>();
+
+ private final StringDescription description = new StringDescription();
+
+ @Test
+ public void testTimeout() {
+ Message msg = new GenericMessage<>("hello");
+ MessageQueueMatcher matcher = MessageQueueMatcher.receivesMessageThat(is(msg)).within(2, TimeUnit.MILLISECONDS);
+
+ boolean result = matcher.matches(queue);
+ assertThat(result, is(false));
+ matcher.describeMismatch(queue, description);
+ assertThat(description.toString(), is("timed out after 2 milliseconds"));
+ }
+
+ @Test
+ public void testMatch() {
+ Message msg = new GenericMessage<>("hello");
+ MessageQueueMatcher matcher = MessageQueueMatcher.receivesMessageThat(is(msg));
+
+ queue.offer(msg);
+
+ boolean result = matcher.matches(queue);
+ assertThat(result, is(true));
+ }
+
+ @Test
+ public void testMisMatch() {
+ Message msg = new GenericMessage<>("hello");
+ Message other = new GenericMessage<>("world");
+
+ MessageQueueMatcher matcher = MessageQueueMatcher.receivesMessageThat(is(msg));
+
+ queue.offer(other);
+
+ boolean result = matcher.matches(queue);
+ assertThat(result, is(false));
+ matcher.describeMismatch(queue, description);
+ assertThat(description.toString(), is("received: <" + other + ">"));
+ }
+
+ @Test
+ public void testExtractor() {
+ Message msg = new GenericMessage<>("hello", Collections.singletonMap("foo", (Object) "bar"));
+
+ MessageQueueMatcher.Extractor, String> headerExtractor = new MessageQueueMatcher.Extractor, String>("whose 'foo' header") {
+ @Override
+ public String apply(Message message) {
+ return message.getHeaders().get("foo", String.class);
+ }
+ };
+
+ MessageQueueMatcher matcher = new MessageQueueMatcher<>(is("bar"), -1, null, headerExtractor);
+ queue.offer(msg);
+ boolean result = matcher.matches(queue);
+ assertThat(result, is(true));
+
+ matcher = new MessageQueueMatcher<>(is("wizz"), -1, null, headerExtractor);
+ queue.offer(msg);
+ result = matcher.matches(queue);
+ assertThat(result, is(false));
+ matcher.describeMismatch(queue, description);
+ assertThat(description.toString(), is("received: \"bar\""));
+ }
+
+ @Test
+ public void testDescription() {
+ Message msg = new GenericMessage<>("hello");
+
+ MessageQueueMatcher matcher = MessageQueueMatcher.receivesMessageThat(is(msg));
+
+ description.appendDescriptionOf(matcher);
+ assertThat(description.toString(), is("Channel to receive a message that is <" + msg + ">"));
+ }
+}