From 84b63179040166b3ab06419c4d45e7cec64c9440 Mon Sep 17 00:00:00 2001
From: xiangpei <xiangpei@timesnew.cn>
Date: 星期一, 01 七月 2024 17:14:26 +0800
Subject: [PATCH] mq消息
---
src/main/java/com/ycl/jxkg/rabbitmq/product/Product.java | 17 ++++++++++++++---
1 files changed, 14 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/ycl/jxkg/rabbitmq/product/Product.java b/src/main/java/com/ycl/jxkg/rabbitmq/product/Product.java
index e3585e8..587b9a0 100644
--- a/src/main/java/com/ycl/jxkg/rabbitmq/product/Product.java
+++ b/src/main/java/com/ycl/jxkg/rabbitmq/product/Product.java
@@ -4,6 +4,7 @@
import com.ycl.jxkg.rabbitmq.RabbitMqMsgTypeEnum;
import lombok.RequiredArgsConstructor;
import org.springframework.amqp.core.Message;
+import org.springframework.amqp.core.MessageBuilder;
import org.springframework.amqp.core.MessageProperties;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Component;
@@ -20,10 +21,20 @@
private final RabbitTemplate rabbitTemplate;
- public void examMsg() {
+ /**
+ * 鍙戦�佽�冭瘯娑堟伅
+ *
+ * @param examId 鑰冭瘯ID
+ * @param jsonMsg 娑堟伅json
+ * @param delayTime 寤惰繜鏃堕棿锛屾绉�
+ */
+ public void examMsg(Integer examId, String jsonMsg, Long delayTime) {
+ MessageProperties messageProperties = new MessageProperties();
+ messageProperties.setExpiration(delayTime + "");
+ Message message = MessageBuilder.withBody(jsonMsg.getBytes()).andProperties(messageProperties).build();
// 璁剧疆娑堟伅鐨勫叧鑱旀暟鎹紝浠ヤ究鍙戦�佺‘璁ゅ洖璋冦�佹湭璺敱鎴愬姛娑堟伅鐨勫鐞�
- MyCorrelationData msgCorrelationData = new MyCorrelationData("ddddd", RabbitMqMsgTypeEnum.EXAM);
- rabbitTemplate.convertAndSend("examDlxQueue", (Object) "浣犲ソ锛孯abbitMQ", msgCorrelationData);
+ MyCorrelationData msgCorrelationData = new MyCorrelationData(examId + "", RabbitMqMsgTypeEnum.EXAM);
+ rabbitTemplate.convertAndSend("examExchange", "exam", message, msgCorrelationData);
}
public void meetMsg() {
--
Gitblit v1.8.0