Fix validate message bug

qunarcorp · May 1, 2019 · 3d6933f · 3d6933f · monir12342 · Sep 14, 2019
1 parent 7b7b456
commit 3d6933f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/qmq-client/src/main/java/qunar/tc/qmq/producer/sender/NettyRouterManager.java b/qmq-client/src/main/java/qunar/tc/qmq/producer/sender/NettyRouterManager.java
@@ -68,8 +68,8 @@ public void validateMessage(Message message) {
         Map<String, Object> attrs = message.getAttrs();
         if (attrs == null) return;
         for (Map.Entry<String, Object> entry : attrs.entrySet()) {
-            if (entry.getValue() == null) return;
-            if (!(entry.getValue() instanceof String)) return;
+            if (entry.getValue() == null) continue;
+            if (!(entry.getValue() instanceof String)) continue;
 
             String value = (String) entry.getValue();
             if (value.length() > _32K) {