old mode 100644
new mode 100755
| | |
|---|
| | | import java.util.Iterator; |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.concurrent.ConcurrentLinkedQueue; |
|---|
| | | import java.util.concurrent.atomic.AtomicBoolean; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 目录查询的回复 |
|---|
| | |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private SipConfig sipConfig; |
|---|
| | | private AtomicBoolean processing = new AtomicBoolean(false); |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void afterPropertiesSet() throws Exception { |
|---|
| | |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void handForDevice(RequestEvent evt, Device device, Element element) { |
|---|
| | | boolean isEmpty = taskQueue.isEmpty(); |
|---|
| | | taskQueue.offer(new HandlerCatchData(evt, device, element)); |
|---|
| | | // 回复200 OK |
|---|
| | | try { |
|---|
| | |
|---|
| | | } catch (SipException | InvalidArgumentException | ParseException e) { |
|---|
| | | logger.error("[命令发送失败] 目录查询回复: {}", e.getMessage()); |
|---|
| | | } |
|---|
| | | // 如果不为空则说明已经开启消息处理 |
|---|
| | | if (isEmpty) { |
|---|
| | | // 已经开启消息处理则跳过 |
|---|
| | | if (processing.compareAndSet(false, true)) { |
|---|
| | | taskExecutor.execute(() -> { |
|---|
| | | while (!taskQueue.isEmpty()) { |
|---|
| | | // 全局异常捕获，保证下一条可以得到处理 |
|---|
| | |
|---|
| | | logger.error("[收到通道] 异常内容： ", e); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | processing.set(false); |
|---|
| | | }); |
|---|
| | | } |
|---|
| | | |
|---|
