feat: 设置 correlationData 后置处理

Author: cadecode

common/plugin/mq/src/main/java/com/github/cadecode/uniboot/common/plugin/mq/rabbit/RabbitCallback.java

@@ -79,5 +79,13 @@ public void afterPropertiesSet() {
         // 设置回调
         rabbitTemplate.setConfirmCallback(this);
         rabbitTemplate.setReturnsCallback(this);
+        // 设置 correlationData 后置处理
+        rabbitTemplate.setCorrelationDataPostProcessor((message, correlationData) -> {
+            // 填充 correlationDataId 到 MessageProperties
+            if (ObjectUtil.isNotNull(correlationData.getId())) {
+                message.getMessageProperties().setCorrelationId(correlationData.getId());
+            }
+            return correlationData;
+        });
     }
 }