| | |
|---|
| | | this.session = session; |
|---|
| | | //这个一定要写，第一次很容易忽略！ |
|---|
| | | webSocketSet.add(this); |
|---|
| | | |
|---|
| | | int flag = param.indexOf("&"); |
|---|
| | | int regionCodeIndex = param.indexOf("_"); |
|---|
| | | orgId = param.substring(0, flag); |
|---|
| | | accountId = param.substring(flag + 1,regionCodeIndex); |
|---|
| | | regionCode = param.substring(regionCodeIndex + 1); |
|---|
| | | String QUEUE_NAME = "deviceInfo_" + accountId; |
|---|
| | | |
|---|
| | | Map<String, Object> paramMap = new HashMap<String, Object>(); |
|---|
| | | paramMap.put("orgId", orgId); |
|---|
| | | paramMap.put("regionCode", regionCode); |
|---|
| | | ParameterUtils.getRegionType4RegionCode(paramMap); |
|---|
| | | List<Device> deviceList = deviceService.queryDevice(paramMap); |
|---|
| | | |
|---|
| | | |
|---|
| | | try { |
|---|
| | | //打开连接和创建频道，与发送端一样 |
|---|
| | | ConnectionFactory factory = new ConnectionFactory(); |
|---|
