MQ的可靠性投递优化

28823be8 · 周晓航 · e7851f72 · 28823be8
Commit 28823be8 authored Aug 19, 2022 by 周晓航
Hide whitespace changes
Inline Side-by-side

Showing with 3 additions and 1 deletions

call-back-service/src/main/java/cn/freemud/amp/service/SendMQConfirmCallback.java
+3 -1

No files found.
--- a/call-back-service/src/main/java/cn/freemud/amp/service/SendMQConfirmCallback.java
+++ b/call-back-service/src/main/java/cn/freemud/amp/service/SendMQConfirmCallback.java
@@ -39,7 +39,9 @@ public class SendMQConfirmCallback {


    public void convertAndSend(String exchange, String queueName, final Object object) {
-        this.rabbitTemplate.convertAndSend(exchange, queueName, object);
+        CorrelationData data = new CorrelationData();
+        data.setId("fisherman_" + System.currentTimeMillis());
+        this.rabbitTemplate.convertAndSend(exchange, queueName, object, data);
    }

    /**