|
@@ -1,24 +1,23 @@
|
|
|
-package cn.iocoder.yudao.server.framework.redis.core.stream;
|
|
|
+package cn.iocoder.yudao.module.system.mq;
|
|
|
|
|
|
import cn.hutool.core.thread.ThreadUtil;
|
|
|
-import cn.iocoder.yudao.server.BaseRedisIntegrationTest;
|
|
|
-import cn.iocoder.yudao.module.system.mq.consumer.mail.SysMailSendConsumer;
|
|
|
-import cn.iocoder.yudao.module.system.mq.consumer.sms.SysSmsSendConsumer;
|
|
|
-import cn.iocoder.yudao.module.system.mq.message.mail.SysMailSendMessage;
|
|
|
-import cn.iocoder.yudao.module.system.mq.message.sms.SysSmsSendMessage;
|
|
|
-import cn.iocoder.yudao.framework.mq.core.util.RedisMessageUtils;
|
|
|
+import cn.iocoder.yudao.framework.mq.core.RedisMQTemplate;
|
|
|
+import cn.iocoder.yudao.module.system.mq.consumer.mail.MailSendConsumer;
|
|
|
+import cn.iocoder.yudao.module.system.mq.consumer.sms.SmsSendConsumer;
|
|
|
+import cn.iocoder.yudao.module.system.mq.message.mail.MailSendMessage;
|
|
|
+import cn.iocoder.yudao.module.system.mq.message.sms.SmsSendMessage;
|
|
|
+import cn.iocoder.yudao.module.system.test.BaseRedisIntegrationTest;
|
|
|
import org.junit.jupiter.api.Disabled;
|
|
|
import org.junit.jupiter.api.Test;
|
|
|
import org.springframework.context.annotation.Import;
|
|
|
import org.springframework.data.redis.core.RedisTemplate;
|
|
|
-import org.springframework.data.redis.core.StringRedisTemplate;
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
|
import java.util.concurrent.TimeUnit;
|
|
|
|
|
|
public class RedisStreamTest {
|
|
|
|
|
|
- @Import({SysSmsSendConsumer.class, SysMailSendConsumer.class})
|
|
|
+ @Import({SmsSendConsumer.class, MailSendConsumer.class})
|
|
|
@Disabled
|
|
|
public static class ConsumerTest extends BaseRedisIntegrationTest {
|
|
|
|
|
@@ -33,7 +32,7 @@ public class RedisStreamTest {
|
|
|
public static class ProducerTest extends BaseRedisIntegrationTest {
|
|
|
|
|
|
@Resource
|
|
|
- private StringRedisTemplate stringRedisTemplate;
|
|
|
+ private RedisMQTemplate redisMQTemplate;
|
|
|
|
|
|
@Resource
|
|
|
private RedisTemplate<String, Object> redisTemplate;
|
|
@@ -42,20 +41,20 @@ public class RedisStreamTest {
|
|
|
public void testProducer01() {
|
|
|
for (int i = 0; i < 100; i++) {
|
|
|
// 创建消息
|
|
|
- SysSmsSendMessage message = new SysSmsSendMessage();
|
|
|
+ SmsSendMessage message = new SmsSendMessage();
|
|
|
message.setMobile("15601691300").setApiTemplateId("test:" + i);
|
|
|
// 发送消息
|
|
|
- RedisMessageUtils.sendStreamMessage(stringRedisTemplate, message);
|
|
|
+ redisMQTemplate.send(message);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@Test
|
|
|
public void testProducer02() {
|
|
|
// 创建消息
|
|
|
- SysMailSendMessage message = new SysMailSendMessage();
|
|
|
+ MailSendMessage message = new MailSendMessage();
|
|
|
message.setAddress("fangfang@mihayou.com").setTemplateCode("test");
|
|
|
// 发送消息
|
|
|
- RedisMessageUtils.sendStreamMessage(stringRedisTemplate, message);
|
|
|
+ redisMQTemplate.send(message);
|
|
|
}
|
|
|
|
|
|
}
|