From ef81a5cbfbb98974ed1ba54d0e47b7e74a9b96b9 Mon Sep 17 00:00:00 2001
From: liusheng <337615773@qq.com>
Date: 星期四, 06 六月 2024 15:33:55 +0800
Subject: [PATCH] 代码提交
---
smartor/src/main/java/com/smartor/config/RabbitMqCallPhoneConfig.java | 9 ++++++---
1 files changed, 6 insertions(+), 3 deletions(-)
diff --git a/smartor/src/main/java/com/smartor/config/RabbitMqCallPhoneConfig.java b/smartor/src/main/java/com/smartor/config/RabbitMqCallPhoneConfig.java
index de3d53a..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);
@@ -107,7 +110,7 @@
@Bean
public void createMq() {
createRabbitMq("phone_exchange", "ob_queue", "phone.ob1");
- createRabbitMq("phone_exchange", "phone_queue", "phone.123");
+ createRabbitMq("phone_exchange", "task_queue", "phone.123");
}
}
--
Gitblit v1.9.3