
某文件示例
package cn.xxx.crm.boss;
import cn.xxxx.crm.manager.mq.rabbit.AliyunCredentialsProvider;
import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.HashMap;
import java.util.UUID;
import java.util.concurrent.TimeoutException;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
/**
* @author zss
* @date 2022/4/25 14:55
* @Email:451682479@qq.com
*/
public class MqTest {
public static final String HOST = "qwer.mq-amqp.cn-hangzhou-111111-a.aliyuncs.com";
public static final String resourceOwnerId = "qwert";
public static final String USERNAME = "aaaaa";
public stat