Commit e5856a9f91b92a3184a8ec332dd93206d34feb87
1 parent
f2f70fce
修复ack超时事件异常执行的bug
Showing
1 changed file
with
1 additions
and
0 deletions
src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/AckRequestProcessor.java
| @@ -90,6 +90,7 @@ public class AckRequestProcessor extends SIPRequestProcessorParent implements In | @@ -90,6 +90,7 @@ public class AckRequestProcessor extends SIPRequestProcessorParent implements In | ||
| 90 | @Override | 90 | @Override |
| 91 | public void process(RequestEvent evt) { | 91 | public void process(RequestEvent evt) { |
| 92 | CallIdHeader callIdHeader = (CallIdHeader)evt.getRequest().getHeader(CallIdHeader.NAME); | 92 | CallIdHeader callIdHeader = (CallIdHeader)evt.getRequest().getHeader(CallIdHeader.NAME); |
| 93 | + dynamicTask.stop(callIdHeader.getCallId()); | ||
| 93 | String fromUserId = ((SipURI) ((HeaderAddress) evt.getRequest().getHeader(FromHeader.NAME)).getAddress().getURI()).getUser(); | 94 | String fromUserId = ((SipURI) ((HeaderAddress) evt.getRequest().getHeader(FromHeader.NAME)).getAddress().getURI()).getUser(); |
| 94 | String toUserId = ((SipURI) ((HeaderAddress) evt.getRequest().getHeader(ToHeader.NAME)).getAddress().getURI()).getUser(); | 95 | String toUserId = ((SipURI) ((HeaderAddress) evt.getRequest().getHeader(ToHeader.NAME)).getAddress().getURI()).getUser(); |
| 95 | logger.info("[收到ACK]: 来自->{}", fromUserId); | 96 | logger.info("[收到ACK]: 来自->{}", fromUserId); |