From 2fd0e1f211744ca3fb135066d931c3e6ec8d9c94 Mon Sep 17 00:00:00 2001
From: zhanghua <314079846@qq.com>
Date: 星期一, 28 十月 2024 18:31:00 +0800
Subject: [PATCH] 12.学生列表中的添加学生 14.题目难度导入 17.建议时长
---
src/main/java/com/ycl/jxkg/rabbitmq/product/Producer.java | 11 ++++++++---
1 files changed, 8 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/ycl/jxkg/rabbitmq/product/Producer.java b/src/main/java/com/ycl/jxkg/rabbitmq/product/Producer.java
index eb1420d..aeabc0c 100644
--- a/src/main/java/com/ycl/jxkg/rabbitmq/product/Producer.java
+++ b/src/main/java/com/ycl/jxkg/rabbitmq/product/Producer.java
@@ -34,11 +34,16 @@
Message message = MessageBuilder.withBody(jsonMsg.getBytes()).andProperties(messageProperties).build();
// 璁剧疆娑堟伅鐨勫叧鑱旀暟鎹紝浠ヤ究鍙戦�佺‘璁ゅ洖璋冦�佹湭璺敱鎴愬姛娑堟伅鐨勫鐞�
MyCorrelationData msgCorrelationData = new MyCorrelationData(examId + "", RabbitMqMsgTypeEnum.EXAM);
- rabbitTemplate.convertAndSend("examExchange", "exam", message, msgCorrelationData);
+ rabbitTemplate.convertAndSend("jxkgExchange", "exam", message, msgCorrelationData);
}
- public void meetMsg(Integer examId, String jsonMsg, Long delayTime) {
- rabbitTemplate.convertAndSend("examExchange","meet", "浣犲ソ锛孯abbitMQ");
+ public void meetMsg(Integer meetId, String jsonMsg, Long delayTime) {
+ MessageProperties messageProperties = new MessageProperties();
+ messageProperties.setExpiration(delayTime + "");
+ Message message = MessageBuilder.withBody(jsonMsg.getBytes()).andProperties(messageProperties).build();
+ // 璁剧疆娑堟伅鐨勫叧鑱旀暟鎹紝浠ヤ究鍙戦�佺‘璁ゅ洖璋冦�佹湭璺敱鎴愬姛娑堟伅鐨勫鐞�
+ MyCorrelationData msgCorrelationData = new MyCorrelationData(meetId + "", RabbitMqMsgTypeEnum.MEET);
+ rabbitTemplate.convertAndSend("jxkgExchange", "meet", message, msgCorrelationData);
}
}
--
Gitblit v1.8.0