From 2cba0d00dc45998105129a0c26cb546282cd39a8 Mon Sep 17 00:00:00 2001
From: liusheng <337615773@qq.com>
Date: 星期三, 05 六月 2024 13:44:23 +0800
Subject: [PATCH] 随访功能测试：模板、任务、定时发送、公众号发送，流程走通
---
smartor/src/main/java/com/smartor/config/RabbitMqCallPhoneConfig.java | 7 +++++--
1 files changed, 5 insertions(+), 2 deletions(-)
diff --git a/smartor/src/main/java/com/smartor/config/RabbitMqCallPhoneConfig.java b/smartor/src/main/java/com/smartor/config/RabbitMqCallPhoneConfig.java
index e36bcd1..7174106 100644
--- a/smartor/src/main/java/com/smartor/config/RabbitMqCallPhoneConfig.java
+++ b/smartor/src/main/java/com/smartor/config/RabbitMqCallPhoneConfig.java
@@ -1,12 +1,16 @@
package com.smartor.config;
+import org.springframework.amqp.AmqpException;
import org.springframework.amqp.core.*;
+import org.springframework.amqp.rabbit.connection.CorrelationData;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;
import java.util.HashMap;
import java.util.Map;
+import java.util.UUID;
@Component
public class RabbitMqCallPhoneConfig {
@@ -15,7 +19,7 @@
private AmqpAdmin amqpAdmin;
@Autowired
- private AmqpTemplate rabbitTemplate;
+ private RabbitTemplate rabbitTemplate;
/**
* 鍒涘缓浜ゆ崲鏈�
@@ -59,7 +63,6 @@
* @param data 娑堟伅
*/
public void sendMessage(String changeName, String routingKey, String data, Long times) {
-
this.rabbitTemplate.convertAndSend(changeName, routingKey, data, message -> {
//娉ㄦ剰杩欓噷鏃堕棿鍙互浣縧ong锛岃�屼笖鏄缃甴eader
message.getMessageProperties().setHeader("x-delay", times);
--
Gitblit v1.9.3