|
|
@ -36,7 +36,7 @@ import java.util.stream.Collectors; |
|
|
import static com.thing.thing.cache.service.CacheInit.KEY; |
|
|
import static com.thing.thing.cache.service.CacheInit.KEY; |
|
|
|
|
|
|
|
|
@Slf4j |
|
|
@Slf4j |
|
|
@Component |
|
|
|
|
|
|
|
|
//@Component |
|
|
@RequiredArgsConstructor |
|
|
@RequiredArgsConstructor |
|
|
public class QueueDeviceEventListener { |
|
|
public class QueueDeviceEventListener { |
|
|
|
|
|
|
|
|
@ -49,7 +49,7 @@ public class QueueDeviceEventListener { |
|
|
|
|
|
|
|
|
private final ReentrantLock lock = new ReentrantLock(); |
|
|
private final ReentrantLock lock = new ReentrantLock(); |
|
|
|
|
|
|
|
|
@EventListener(QueueDeviceEvent.class) |
|
|
|
|
|
|
|
|
// @EventListener(QueueDeviceEvent.class) |
|
|
public void onDeviceEvent(QueueDeviceEvent event) { |
|
|
public void onDeviceEvent(QueueDeviceEvent event) { |
|
|
List<QueueMsgDTO> msgList = event.getList(); |
|
|
List<QueueMsgDTO> msgList = event.getList(); |
|
|
if(CollectionUtils.isEmpty(msgList)){ |
|
|
if(CollectionUtils.isEmpty(msgList)){ |
|
|
|