SpringCloudStreamEndToEndTestExample.java

// example application.properties

// spring.cloud.stream.bindings.input.destination=unenriched
// spring.cloud.stream.bindings.input.group=default

// spring.cloud.stream.bindings.output.destination=enriched
// spring.cloud.stream.bindings.output.group=default
// spring.cloud.stream.bindings.output.content-type=application/json


@RunWith(SpringJUnit4ClassRunner.class)
@SpringApplicationConfiguration(classes = com.example.EnricherApplication.class)
@IntegrationTest()
public class EnricherTest {
    @Autowired
    TestMessageBroker testMessageBroker;

    @Before
    public void setUp() throws Exception {
        testMessageBroker.purgeAll();
    }

    @Test
    public void messageGetsEnrichedWithMyCoolField() throws Exception {
        testMessageBroker.forTopic("unenriched.default").send("{\"foo\":\"bar\"}");

        String result = testMessageBroker.forTopic("enriched.default").poll();
        assertEquals(result, "{\"foo\":\"bar\",\"myCoolField\":12345}");
    }
}