update

ZhuDongming

2020-06-30 712a73114593e64ae3126f9bb531d968f3581394

 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();