From 7fa83e5dd03f7896bd1d1e8c47f5e926ff3d4ba0 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 16 十月 2024 14:12:24 +0800
Subject: [PATCH] CMQ改造为rabbitmq
---
service-push/src/test/java/com/ks/push/TaskTest.java | 13 +++++++++++++
1 files changed, 13 insertions(+), 0 deletions(-)
diff --git a/service-push/src/test/java/com/ks/push/TaskTest.java b/service-push/src/test/java/com/ks/push/TaskTest.java
index 38e4cc4..6d1b539 100644
--- a/service-push/src/test/java/com/ks/push/TaskTest.java
+++ b/service-push/src/test/java/com/ks/push/TaskTest.java
@@ -1,11 +1,14 @@
package com.ks.push;
+import com.google.gson.Gson;
import com.ks.push.exception.BPushTaskException;
+import com.ks.push.manager.rabbitmq.RabbitmqSenderUtil;
import com.ks.push.pojo.DO.BPushFilter;
import com.ks.push.pojo.DO.BPushMessage;
import com.ks.push.pojo.DO.BPushTask;
import com.ks.push.service.BPushTaskService;
import org.junit.jupiter.api.Test;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.ContextConfiguration;
@@ -37,4 +40,14 @@
bPushTaskService.createTask(task);
}
+ @Resource
+ private RabbitTemplate rabbitTemplate;
+
+
+ @Test
+ public void testRabbitMq(){
+ RabbitmqSenderUtil.sendQueueMsg(rabbitTemplate, "test", "娴嬭瘯鍐呭");
+
+ }
+
}
--
Gitblit v1.8.0