From 0a1f7120945f04e82c556b19996c3b428e14a99b Mon Sep 17 00:00:00 2001 From: caotc <250622148@qq.com> Date: Mon, 26 Aug 2019 15:28:20 +0800 Subject: [PATCH] =?UTF-8?q?=E5=B0=86rocketmq=E7=9A=84header=E8=BD=AC?= =?UTF-8?q?=E6=8D=A2=E4=B8=BAspring=E7=9A=84header=E6=97=B6=E4=B9=9F?= =?UTF-8?q?=E8=BF=9B=E8=A1=8C=E8=BF=87=E6=BB=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: caotc <250622148@qq.com> --- .../binder/rocketmq/support/JacksonRocketMQHeaderMapper.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/support/JacksonRocketMQHeaderMapper.java b/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/support/JacksonRocketMQHeaderMapper.java index c3d1d83c8..db5d446ba 100644 --- a/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/support/JacksonRocketMQHeaderMapper.java +++ b/spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/support/JacksonRocketMQHeaderMapper.java @@ -87,7 +87,7 @@ public class JacksonRocketMQHeaderMapper extends AbstractRocketMQHeaderMapper{ final Map target = Maps.newHashMap(); final Map jsonTypes = decodeJsonTypes(source); source.forEach((key,value) -> { - if (!(key.equals(JSON_TYPES))) { + if (matches(key) && !(key.equals(JSON_TYPES))) { if (jsonTypes != null && jsonTypes.containsKey(key)) { Class type = Object.class; String requestedType = jsonTypes.get(key); @@ -113,8 +113,7 @@ public class JacksonRocketMQHeaderMapper extends AbstractRocketMQHeaderMapper{ }else { target.put(key, new NonTrustedHeaderType(value, requestedType)); } - } - else { + }else { target.put(key, value); } }