Open duke88 opened 6 years ago
NSQConfig使用clone后的扩展消息过滤数据存储map并没有真正clone,还是使用原来的map引用,后来查看源码内部的Map,好像并不支持clone.
private Map<ConsumePolicy, Map<String, Object>> consumePolicyMap = new ConcurrentHashMap<>();
NSQConfig使用clone后的扩展消息过滤数据存储map并没有真正clone,还是使用原来的map引用,后来查看源码内部的Map,好像并不支持clone.
private Map<ConsumePolicy, Map<String, Object>> consumePolicyMap = new ConcurrentHashMap<>();