diff --git a/spring-cloud-stream-reactive/src/test/java/org/springframework/cloud/stream/reactive/StreamEmitterBasicTests.java b/spring-cloud-stream-reactive/src/test/java/org/springframework/cloud/stream/reactive/StreamEmitterBasicTests.java
index 1e45fea35..4060b3a5d 100644
--- a/spring-cloud-stream-reactive/src/test/java/org/springframework/cloud/stream/reactive/StreamEmitterBasicTests.java
+++ b/spring-cloud-stream-reactive/src/test/java/org/springframework/cloud/stream/reactive/StreamEmitterBasicTests.java
@@ -21,6 +21,7 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
+import java.util.function.Supplier;
 
 import org.junit.Test;
 import org.reactivestreams.Publisher;
@@ -230,8 +231,9 @@ public class StreamEmitterBasicTests {
 		@Bean
 		public Publisher<Message<String>> emit() {
 			AtomicInteger atomicInteger = new AtomicInteger();
+
 			return IntegrationFlows
-					.from(() -> new GenericMessage<>(
+					.from((Supplier<?>) () -> new GenericMessage<>(
 							"Hello World!!" + atomicInteger.getAndIncrement()),
 							e -> e.poller(p -> p.fixedDelay(1)))
 					.<String, String>transform(String::toUpperCase).toReactivePublisher();
diff --git a/spring-cloud-stream/pom.xml b/spring-cloud-stream/pom.xml
index da5b06751..ca8b37c86 100644
--- a/spring-cloud-stream/pom.xml
+++ b/spring-cloud-stream/pom.xml
@@ -76,6 +76,21 @@
 			<artifactId>spring-boot-starter-web</artifactId>
 			<scope>test</scope>
 		</dependency>
+		<dependency>
+		  <groupId>javax.xml.bind</groupId>
+		  <artifactId>jaxb-api</artifactId>
+		  <version>2.3.0</version>
+		</dependency>
+		<dependency>
+		  <groupId>com.sun.xml.bind</groupId>
+		  <artifactId>jaxb-core</artifactId>
+		  <version>2.3.0</version>
+		</dependency>
+		<dependency>
+		  <groupId>com.sun.xml.bind</groupId>
+		  <artifactId>jaxb-impl</artifactId>
+		  <version>2.3.0</version>
+		</dependency>
 	</dependencies>
 
 	<build>