服务器指定token队列的支持

yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/impl/MqServiceImpl.java

@@ -216,9 +216,10 @@ public class MqServiceImpl implements MqService {
         String queueName = req.getQueueName();
         String localQueueName = this.getLocalName(req.getQueueName());
         String serverId = StringHelper.getMD5Id(localQueueName);
+        String serverTokenId = StringHelper.getMD5Id(req.getToken(), queueName);
 
         QueueServerTokenVo serverTokenVo = new QueueServerTokenVo();
-        serverTokenVo.setServerTokenId(StringHelper.getMD5Id(req.getToken(), queueName));
+        serverTokenVo.setServerTokenId(serverTokenId);
         serverTokenVo.setQueueName(queueName);
         serverTokenVo.setTokenId(req.getToken());
         serverTokenVo.setServerId(serverId);
@@ -235,8 +236,9 @@ public class MqServiceImpl implements MqService {
 
     @Override
     public void removeToken(RegisterServerTokenReqVo req) {
-        String serverId = StringHelper.getMD5Id(localName);
-
+        String queueName = req.getQueueName();
+        String serverTokenId = StringHelper.getMD5Id(req.getToken(), queueName);
+        queueServerTokenDao.remove(serverTokenId);
     }
 
     @Override