From 1b9c72bddb3265bd4bcaa2f58dc94a0a52b577cb Mon Sep 17 00:00:00 2001 From: Marius Bogoevici Date: Thu, 26 Jan 2017 14:43:39 -0500 Subject: [PATCH] Allow subclasses of AbstractBinder access to deserialization logic --- .../springframework/cloud/stream/binder/AbstractBinder.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 d3734435b..3f02d67bb 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 @@ -203,11 +203,11 @@ public abstract class AbstractBinder message) { + protected final MessageValues deserializePayloadIfNecessary(Message message) { return deserializePayloadIfNecessary(new MessageValues(message)); } - final MessageValues deserializePayloadIfNecessary(MessageValues messageValues) { + protected final MessageValues deserializePayloadIfNecessary(MessageValues messageValues) { Object originalPayload = messageValues.getPayload(); MimeType contentType = this.contentTypeResolver.resolve(messageValues); Object payload = deserializePayload(originalPayload, contentType);