| | |
|---|
| | | package com.genersoft.iot.vmp.service.redisMsg; |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson.JSON; |
|---|
| | | import com.alibaba.fastjson.JSONObject; |
|---|
| | | import com.alibaba.fastjson2.JSON; |
|---|
| | | import com.alibaba.fastjson2.JSONObject; |
|---|
| | | import com.genersoft.iot.vmp.media.zlm.dto.StreamPushItem; |
|---|
| | | import com.genersoft.iot.vmp.service.IGbStreamService; |
|---|
| | | import com.genersoft.iot.vmp.service.IMediaServerService; |
|---|
| | |
|---|
| | | |
|---|
| | | private boolean taskQueueHandlerRun = false; |
|---|
| | | |
|---|
| | | private final ConcurrentLinkedQueue<Message> taskQueue = new ConcurrentLinkedQueue<>(); |
|---|
| | | private ConcurrentLinkedQueue<Message> taskQueue = new ConcurrentLinkedQueue<>(); |
|---|
| | | |
|---|
| | | @Qualifier("taskExecutor") |
|---|
| | | @Autowired |
|---|
