/** * 开源代码,仅供学习和交流研究使用,商用请联系三丙 * 微信:mohan_88888 * 抖音:程序员三丙 * 付费课程知识星球:https://t.zsxq.com/aKtXo */ package sanbing.jcpp.infrastructure.queue; import java.util.HashMap; import java.util.Map; public class DefaultQueueMsgHeaders implements QueueMsgHeaders { protected final Map data = new HashMap<>(); @Override public byte[] put(String key, byte[] value) { return data.put(key, value); } @Override public byte[] get(String key) { return data.get(key); } @Override public Map getData() { return data; } }