From dabee4ed7d503a06a78a7c12491416206a48eec1 Mon Sep 17 00:00:00 2001 From: XiaoQiTong <69035114+XiaoQiTong@users.noreply.github.com> Date: 星期六, 15 十月 2022 20:57:24 +0800 Subject: [PATCH] 增加指定流媒体收流功能 --- src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/NotifyRequestProcessor.java | 5 ++--- 1 files changed, 2 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/NotifyRequestProcessor.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/NotifyRequestProcessor.java index 206a159..f78ee18 100644 --- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/NotifyRequestProcessor.java +++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/NotifyRequestProcessor.java @@ -79,7 +79,7 @@ private boolean taskQueueHandlerRun = false; - private final ConcurrentLinkedQueue<HandlerCatchData> taskQueue = new ConcurrentLinkedQueue<>(); + private ConcurrentLinkedQueue<HandlerCatchData> taskQueue = new ConcurrentLinkedQueue<>(); @Qualifier("taskExecutor") @Autowired @@ -124,10 +124,9 @@ } } catch (DocumentException e) { logger.error("澶勭悊NOTIFY娑堟伅鏃堕敊璇�", e); - } finally { - taskQueueHandlerRun = false; } } + taskQueueHandlerRun = false; }); } } catch (SipException | InvalidArgumentException | ParseException e) { -- Gitblit v1.8.0