Update SIPCommander.java
This commit is contained in:
@@ -1139,7 +1139,7 @@ public class SIPCommander implements ISIPCommander {
|
|||||||
MessageEvent<Object> messageEvent = MessageEvent.getInstance(cmdType, sn + "", channelId, 4000L, callback);
|
MessageEvent<Object> messageEvent = MessageEvent.getInstance(cmdType, sn + "", channelId, 4000L, callback);
|
||||||
messageSubscribe.addSubscribe(messageEvent);
|
messageSubscribe.addSubscribe(messageEvent);
|
||||||
log.info("[预置位查询] 设备编号: {}, 通道编号: {}, SN: {}", device.getDeviceId(), channelId, sn);
|
log.info("[预置位查询] 设备编号: {}, 通道编号: {}, SN: {}", device.getDeviceId(), channelId, sn);
|
||||||
Request request = headerProvider.createMessageRequest(device, cmdXml.toString(), null, SipUtils.getNewFromTag(), SipUtils.getNewViaTag(),sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()));
|
Request request = headerProvider.createMessageRequest(device, cmdXml.toString(), SipUtils.getNewViaTag(), SipUtils.getNewFromTag(), null,sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()));
|
||||||
sipSender.transmitRequest(sipLayer.getLocalIp(device.getLocalIp()), request, eventResult -> {
|
sipSender.transmitRequest(sipLayer.getLocalIp(device.getLocalIp()), request, eventResult -> {
|
||||||
messageSubscribe.removeSubscribe(messageEvent.getKey());
|
messageSubscribe.removeSubscribe(messageEvent.getKey());
|
||||||
callback.run(ErrorCode.ERROR100.getCode(), "失败," + eventResult.msg, null);
|
callback.run(ErrorCode.ERROR100.getCode(), "失败," + eventResult.msg, null);
|
||||||
|
|||||||
Reference in New Issue
Block a user