ZhuDongming
2020-06-30 39a23e8fde4d9b7fc930543ea9e495e419d12017
src/main/java/com/moral/webSocketServer/WebSocketServer.java
@@ -37,7 +37,7 @@
    private String orgId;
    private String regionCode;
    private String accountId;
    private Connection connection;
@@ -58,8 +58,8 @@
        webSocketSet.add(this);
        int flag = param.indexOf("&");
        orgId = param.substring(0, flag);
        regionCode = param.substring(flag + 1);
        String QUEUE_NAME = "deviceInfo";
        accountId = param.substring(flag + 1);
        String QUEUE_NAME = "deviceInfo_"+accountId;
        try {
            //打开连接和创建频道,与发送端一样
            ConnectionFactory factory = new ConnectionFactory();