From cb73f26466fe4a62a9a6db979c1d48d96ea00eef Mon Sep 17 00:00:00 2001 From: Marius Bogoevici Date: Fri, 4 Mar 2016 12:06:37 -0500 Subject: [PATCH] Support `application/json` content type sent by non-SCSt applications Fixes #399 --- .../springframework/cloud/stream/binder/AbstractBinder.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/AbstractBinder.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/AbstractBinder.java index 9bc1d2d4f..a5a2bae91 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/AbstractBinder.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/AbstractBinder.java @@ -16,6 +16,7 @@ package org.springframework.cloud.stream.binder; +import static org.springframework.util.MimeTypeUtils.APPLICATION_JSON; import static org.springframework.util.MimeTypeUtils.APPLICATION_OCTET_STREAM; import static org.springframework.util.MimeTypeUtils.TEXT_PLAIN; @@ -425,7 +426,7 @@ public abstract class AbstractBinder implements ApplicationContextAware, Init } private Object deserializePayload(byte[] bytes, MimeType contentType) { - if (TEXT_PLAIN.equals(contentType)) { + if (TEXT_PLAIN.equals(contentType) || APPLICATION_JSON.equals(contentType)) { try { return new String(bytes, "UTF-8"); }