Commit 4701b749 authored by yanzg's avatar yanzg

接口文档的支持

parent 353c94ec
......@@ -221,7 +221,6 @@ public class MqServiceImpl implements MqService {
*/
@Override
public String setServerQueueConsumer(ServerQueueReqVo req, ChannelAwareMessageListener listener) {
String queueName = req.getQueueName();
String localQueueName = this.getLocalName(req.getQueueName());
this.mqConsumeDynamic.init(localQueueName, listener);
return "注册成功";
......
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