diff --git a/spring-cloud-contract-verifier/src/main/java/org/springframework/cloud/contract/verifier/messaging/stream/StreamStubMessages.java b/spring-cloud-contract-verifier/src/main/java/org/springframework/cloud/contract/verifier/messaging/stream/StreamStubMessages.java
index d70e5f0831..418edad8f7 100644
--- a/spring-cloud-contract-verifier/src/main/java/org/springframework/cloud/contract/verifier/messaging/stream/StreamStubMessages.java
+++ b/spring-cloud-contract-verifier/src/main/java/org/springframework/cloud/contract/verifier/messaging/stream/StreamStubMessages.java
@@ -32,7 +32,6 @@ import org.springframework.messaging.Message;
 import org.springframework.messaging.MessageChannel;
 import org.springframework.messaging.converter.DefaultContentTypeResolver;
 import org.springframework.messaging.converter.MappingJackson2MessageConverter;
-import org.springframework.messaging.support.MessageBuilder;
 import org.springframework.util.MimeTypeUtils;
 
 /**
@@ -75,12 +74,7 @@ public class StreamStubMessages implements MessageVerifier<Message<?>> {
 		try {
 			MessageChannel messageChannel = this.context
 					.getBean(resolvedDestination(destination), MessageChannel.class);
-			Message<?> message = this.messageCollector.forChannel(messageChannel).poll(timeout, timeUnit);
-			if (message == null) {
-				return message;
-			}
-			Object fromMessage = converter().fromMessage(message, String.class);
-			return MessageBuilder.createMessage(fromMessage, message.getHeaders());
+			return this.messageCollector.forChannel(messageChannel).poll(timeout, timeUnit);
 		}
 		catch (Exception e) {
 			log.error("Exception occurred while trying to read a message from "
@@ -119,20 +113,6 @@ public class StreamStubMessages implements MessageVerifier<Message<?>> {
 		return receive(destination, 5, TimeUnit.SECONDS);
 	}
 
-	private MappingJackson2MessageConverter converter() {
-		ObjectMapper mapper = null;
-		try {
-			mapper = this.context.getBean(ObjectMapper.class);
-		} catch (NoSuchBeanDefinitionException e) {
-
-		}
-		MappingJackson2MessageConverter converter = createJacksonConverter();
-		if (mapper != null) {
-			converter.setObjectMapper(mapper);
-		}
-		return converter;
-	}
-
 	protected MappingJackson2MessageConverter createJacksonConverter() {
 		DefaultContentTypeResolver resolver = new DefaultContentTypeResolver();
 		resolver.setDefaultMimeType(MimeTypeUtils.APPLICATION_JSON);