in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/message/JmsBaseMessage.java [197:212]
public void copyMetaData(JmsBaseMessage sourceMessage) {
if (!sourceMessage.getHeaders().isEmpty()) {
for (Map.Entry<String, Object> entry : sourceMessage.getHeaders().entrySet()) {
if (!exists(entry.getKey())) {
setHeader(entry.getKey(), entry.getValue());
}
}
}
if (!sourceMessage.getProperties().isEmpty()) {
for (Map.Entry<String, Object> entry : sourceMessage.getProperties().entrySet()) {
if (!propertyExists(entry.getKey())) {
setObjectProperty(entry.getKey(), entry.getValue());
}
}
}
}