diff --git a/weixin4j-server/src/main/java/com/foxinmy/weixin4j/socket/WeixinMessageDecoder.java b/weixin4j-server/src/main/java/com/foxinmy/weixin4j/socket/WeixinMessageDecoder.java index 83dd14b1..833913f8 100644 --- a/weixin4j-server/src/main/java/com/foxinmy/weixin4j/socket/WeixinMessageDecoder.java +++ b/weixin4j-server/src/main/java/com/foxinmy/weixin4j/socket/WeixinMessageDecoder.java @@ -11,6 +11,7 @@ import io.netty.util.internal.logging.InternalLoggerFactory; import java.util.List; import java.util.Map; +import java.util.Map.Entry; import java.util.concurrent.ConcurrentHashMap; import com.foxinmy.weixin4j.exception.WeixinException; @@ -40,11 +41,9 @@ public class WeixinMessageDecoder extends private Map aesTokenMap = new ConcurrentHashMap(); - public WeixinMessageDecoder(Map aesTokenMap) { - // this.aesTokenMap = aesTokenMap; - AesToken[] tokens = aesTokenMap.values().toArray(new AesToken[0]); - for (AesToken token : tokens) { - aesTokenMap.put(token.getWeixinId(), token); + public WeixinMessageDecoder(final Map aesTokenMap) { + for (Entry entry : aesTokenMap.entrySet()) { + this.aesTokenMap.put(entry.getKey(), entry.getValue()); } }