package com.matrix;

import com.matrix.component.asyncmessage.AsyncMessageManager;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

import java.io.IOException;
import java.util.HashMap;
import java.util.Map;

/**
 * 测试类示例
 *
 * @author jiangyouyao
 * @email 512061637@qq.com
 * @date 2019年2月25日
 */
@RunWith(SpringRunner.class)
@SpringBootTest(classes = {ZqErpApplication.class}, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
public class TesatAsyncMessage {


    @Autowired
    AsyncMessageManager asyncMessageManager;

    @Test
    public void test() throws IOException {

        Map<String, Object> param =new HashMap<>();
        param.put("test","123");
        asyncMessageManager.sendMsg("testkey",param);
        asyncMessageManager.sendMsg("testkey","test=%s","123456");


    }



}