| | |
|---|
| | | import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | import org.springframework.util.ObjectUtils; |
|---|
| | | import org.springframework.util.StringUtils; |
|---|
| | | |
|---|
| | | import javax.sip.InvalidArgumentException; |
|---|
| | | import javax.sip.RequestEvent; |
|---|
| | |
|---|
| | | @Autowired |
|---|
| | | private IDeviceChannelService deviceChannelService; |
|---|
| | | |
|---|
| | | private boolean taskQueueHandlerRun = false; |
|---|
| | | |
|---|
| | | private ConcurrentLinkedQueue<HandlerCatchData> taskQueue = new ConcurrentLinkedQueue<>(); |
|---|
| | | |
|---|
| | | @Qualifier("taskExecutor") |
|---|
| | |
|---|
| | | }catch (SipException | InvalidArgumentException | ParseException e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | } |
|---|
| | | boolean runed = !taskQueue.isEmpty(); |
|---|
| | | taskQueue.offer(new HandlerCatchData(evt, null, null)); |
|---|
| | | if (!taskQueueHandlerRun) { |
|---|
| | | taskQueueHandlerRun = true; |
|---|
| | | if (!runed) { |
|---|
| | | taskExecutor.execute(()-> { |
|---|
| | | try { |
|---|
| | | while (!taskQueue.isEmpty()) { |
|---|
| | |
|---|
| | | } |
|---|
| | | }catch (Exception e) { |
|---|
| | | logger.error("处理NOTIFY消息时错误", e); |
|---|
| | | }finally { |
|---|
| | | taskQueueHandlerRun = false; |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | } |
|---|
