From 1cd165df463bcd6d51ccde8fb6777b74dac3ba89 Mon Sep 17 00:00:00 2001
From: Oleg Zhurakousky <ozhurakousky@vmware.com>
Date: Thu, 8 Apr 2021 17:16:35 +0200
Subject: [PATCH] Make StreamBridge generate Message if user send just a POJO

---
 .../springframework/cloud/stream/function/StreamBridge.java    | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/StreamBridge.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/StreamBridge.java
index b983b8ace..90004cb08 100644
--- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/StreamBridge.java
+++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/StreamBridge.java
@@ -148,6 +148,9 @@ public final class StreamBridge implements SmartInitializingSingleton {
 	 */
 	@SuppressWarnings("unchecked")
 	public boolean send(String bindingName, Object data, MimeType outputContentType) {
+		if (!(data instanceof Message)) {
+			data = MessageBuilder.withPayload(data).build();
+		}
 		ProducerProperties producerProperties = this.bindingServiceProperties.getProducerProperties(bindingName);
 		SubscribableChannel messageChannel = this.resolveDestination(bindingName, producerProperties);