Commit e85837d8 authored by yanzg's avatar yanzg

修改MQ请求尸体,防止出错

parent fe3eb4a6
...@@ -176,8 +176,6 @@ public class MqServiceImpl implements MqService, InitializingBean { ...@@ -176,8 +176,6 @@ public class MqServiceImpl implements MqService, InitializingBean {
*/ */
@Override @Override
public String createServerQueue(ServerQueueReqVo req) { public String createServerQueue(ServerQueueReqVo req) {
// 删除历史队列
removeServerQueue(req);
// 创建主队列 // 创建主队列
String queueName = req.getQueueName(); String queueName = req.getQueueName();
String localQueueName = this.getLocalName(req.getQueueName()); String localQueueName = this.getLocalName(req.getQueueName());
...@@ -195,6 +193,8 @@ public class MqServiceImpl implements MqService, InitializingBean { ...@@ -195,6 +193,8 @@ public class MqServiceImpl implements MqService, InitializingBean {
*/ */
@Override @Override
public String setServerQueueConsumer(ServerQueueReqVo req, ChannelAwareMessageListener listener) { public String setServerQueueConsumer(ServerQueueReqVo req, ChannelAwareMessageListener listener) {
// 删除历史队列
removeServerQueue(req);
// 队列名称 // 队列名称
String queueName = req.getQueueName(); String queueName = req.getQueueName();
String localQueueName = this.getLocalName(req.getQueueName()); String localQueueName = this.getLocalName(req.getQueueName());
......
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