Commit 95219a40 authored by 赵啸非's avatar 赵啸非

修改提交分辨率更新

parent 2aa073f0
......@@ -767,7 +767,10 @@ public class DeviceServiceImpl extends AbstractCRUDCacheServiceImpl<DeviceDao, D
public boolean restartMessageListener(String queueName) {
try {
String key = StringUtils.trim(queueName);
List<String> queues = Arrays.asList(container.getQueueNames());
if(!queues.contains(key)){
container.addQueueNames(key);
}
if (container.isRunning()) {
container.stop();
container.start();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment