message_bus / message_bus_service · 提交

转到一个项目

作者 xudada
提交 cb953677433897ccb106393d7f27b13b27a1ad84 1 个父辈 a6990954

队列管理删除优化，去掉移除MQ服务器上队列部分

内嵌 并排对比
正在显示 1 个修改的文件 包含 2 行增加 和 2 行删除
@@ -71,7 +71,7 @@ public class BusQueueServiceImpl implements BusQueueService { @@ -71,7 +71,7 @@ public class BusQueueServiceImpl implements BusQueueService {
71 // 删除数据库中的该队列 71 // 删除数据库中的该队列
72 int num = busQueueMapper.deleteByPrimaryKey(split[i]); 72 int num = busQueueMapper.deleteByPrimaryKey(split[i]);
73 // 删除MQ服务器上的队列 73 // 删除MQ服务器上的队列
74 - deleteQueue(busQueue); 74 + //deleteQueue(busQueue);
75 // 级联删除数据库中与队列有关的配置关系 75 // 级联删除数据库中与队列有关的配置关系
76 queueCascadeDelete(busQueue); 76 queueCascadeDelete(busQueue);
77 if (num > 0) { 77 if (num > 0) {
@@ -88,7 +88,7 @@ public class BusQueueServiceImpl implements BusQueueService { @@ -88,7 +88,7 @@ public class BusQueueServiceImpl implements BusQueueService {
88 // 删除数据库中的该队列 88 // 删除数据库中的该队列
89 int num = busQueueMapper.deleteByPrimaryKey(id); 89 int num = busQueueMapper.deleteByPrimaryKey(id);
90 // 删除MQ服务器上的队列 90 // 删除MQ服务器上的队列
91 - deleteQueue(busQueue); 91 + //deleteQueue(busQueue);
92 // 级联删除数据库中与队列有关的配置关系 92 // 级联删除数据库中与队列有关的配置关系
93 queueCascadeDelete(busQueue); 93 queueCascadeDelete(busQueue);
94 return num; 94 return num;