package com.topdraw.test.mq;

import com.alibaba.fastjson.JSON;
import com.topdraw.BaseTest;
import com.topdraw.mq.module.mq.DataSyncMsg;
import com.topdraw.mq.module.mq.EventType;
import com.topdraw.mq.producer.MessageProducer;
import org.junit.Test;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;

public class MqTest extends BaseTest {

    @Autowired
    MessageProducer messageProducer;

    @Autowired
    private AmqpTemplate amqpTemplate;

    @Test
    public void test(){
        DataSyncMsg dataSyncMsg = new DataSyncMsg();
//        dataSyncMsg.setEventType(EventType.LOGIN.name());
        dataSyncMsg.setEvt(EventType.LOGIN.name());
        DataSyncMsg.MsgData msgData = new DataSyncMsg.MsgData();
        msgData.setRemarks("remark");
        msgData.setMemberId(1L);
        msgData.setAppCode("WEI_XIN_GOLD_PANDA");
//        dataSyncMsg.setMsgData(msgData);
        String s = JSON.toJSONString(dataSyncMsg);
        amqpTemplate.convertAndSend( "uc.route.key.direct.event.aaa", s);
    }

}