rabbitmq发送含header的消息

MqSender.java

public void sendMsg(Map<String, String> headerMap, ...)
rabbitTemplate.convertAndSend(exchange, routingKey, msg,
                        message -> {
                            for (Map.Entry<String, String> entry : headerMap.entrySet()) {
                                message.getMessageProperties().setHeader(entry.getKey(), entry.getValue());
                            }
                            return message;
                        })