package com.ks.lucky;
|
|
import com.ks.lucky.pojo.DTO.mq.ActivityJoinMsgDTO;
|
import com.ks.lucky.remote.service.LuckyActivityJoinService;
|
import com.ks.lucky.util.mq.CMQManager;
|
import org.junit.jupiter.api.Test;
|
import org.springframework.boot.test.context.SpringBootTest;
|
|
import javax.annotation.Resource;
|
|
@SpringBootTest
|
public class CMQTest {
|
|
@Resource
|
private LuckyActivityJoinService luckyActivityJoinService;
|
|
@Test
|
public void addJoinMsg() {
|
|
CMQManager.getInstance().publishActivityJoinMsg(ActivityJoinMsgDTO.create(luckyActivityJoinService.getJoinRecord(6L)));
|
}
|
|
}
|
