| 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"); | 
|   | 
|   | 
|     } | 
|   | 
|   | 
|   | 
| } |