优化消息处理中存在可能异常的处理流程

648540858

2022-10-17 0ff4ed217de599e6c6336f0330787b7593641dc4

 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/NotifyRequestProcessor.java

@@ -93,10 +93,13 @@

   @Override
   public void process(RequestEvent evt) {
      try {
         taskQueue.offer(new HandlerCatchData(evt, null, null));
         ServerTransaction serverTransaction = getServerTransaction(evt);
      try {
         responseAck(serverTransaction, Response.OK);
      }catch (SipException | InvalidArgumentException | ParseException e) {
         e.printStackTrace();
      }
      taskQueue.offer(new HandlerCatchData(evt, null, null));
         if (!taskQueueHandlerRun) {
            taskQueueHandlerRun = true;
            taskExecutor.execute(()-> {
@@ -128,11 +131,6 @@
               }
               taskQueueHandlerRun = false;
            });
         }
      } catch (SipException | InvalidArgumentException | ParseException e) {
         e.printStackTrace();
      } finally {
         taskQueueHandlerRun = false;
      }
   }