| | |
|---|
| | | import org.springframework.beans.factory.annotation.Qualifier; |
|---|
| | | 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; |
|---|
| | | import javax.sip.ServerTransaction; |
|---|
| | | import javax.sip.SipException; |
|---|
| | | import javax.sip.header.FromHeader; |
|---|
| | | import javax.sip.message.Response; |
|---|
| | |
|---|
| | | |
|---|
| | | private boolean taskQueueHandlerRun = false; |
|---|
| | | |
|---|
| | | private final ConcurrentLinkedQueue<HandlerCatchData> taskQueue = new ConcurrentLinkedQueue<>(); |
|---|
| | | private ConcurrentLinkedQueue<HandlerCatchData> taskQueue = new ConcurrentLinkedQueue<>(); |
|---|
| | | |
|---|
| | | @Qualifier("taskExecutor") |
|---|
| | | @Autowired |
|---|
| | |
|---|
| | | public void process(RequestEvent evt) { |
|---|
| | | try { |
|---|
| | | taskQueue.offer(new HandlerCatchData(evt, null, null)); |
|---|
| | | responseAck(evt, Response.OK); |
|---|
| | | ServerTransaction serverTransaction = getServerTransaction(evt); |
|---|
| | | responseAck(serverTransaction, Response.OK); |
|---|
| | | if (!taskQueueHandlerRun) { |
|---|
| | | taskQueueHandlerRun = true; |
|---|
| | | taskExecutor.execute(()-> { |
|---|
| | |
|---|
| | | String channelId = deviceIdElement.getTextTrim().toString(); |
|---|
| | | Device device = redisCatchStorage.getDevice(deviceId); |
|---|
| | | if (device != null) { |
|---|
| | | if (!StringUtils.isEmpty(device.getName())) { |
|---|
| | | if (!ObjectUtils.isEmpty(device.getName())) { |
|---|
| | | mobilePosition.setDeviceName(device.getName()); |
|---|
| | | } |
|---|
| | | } |
|---|
