| | |
|---|
| | | Session session = this.get(cmd.getDevId()); |
|---|
| | | if (session == null) { |
|---|
| | | log.error("DevId: {} not online!", cmd.getDevId()); |
|---|
| | | return "-1"; |
|---|
| | | return null; |
|---|
| | | } |
|---|
| | | String requestKey = requestKey(cmd.getDevId(), cmd.getRespId(), cmd.getPackageNo()); |
|---|
| | | SynchronousQueue<String> subscribe = subscribe(requestKey); |
|---|
| | | if (subscribe == null) { |
|---|
| | | log.error("DevId: {} key:{} send repaid", cmd.getDevId(), requestKey); |
|---|
| | | return "-1"; |
|---|
| | | return null; |
|---|
| | | } |
|---|
| | | session.writeObject(cmd); |
|---|
| | | try { |
|---|
| | |
|---|
| | | log.error("{}", e.getMessage(), e); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | log.warn("未找到对应回复指令,key:{} 消息:{} ", requestKey, data); |
|---|
| | | log.warn("Not find response,key:{} data:{} ", requestKey, data); |
|---|
| | | return false; |
|---|
| | | } |
|---|
| | | |
|---|
