Commit 82a9ab7e authored by yanzg's avatar yanzg

消除成功接收处理

parent e34111a4
...@@ -53,8 +53,9 @@ public interface MessageService { ...@@ -53,8 +53,9 @@ public interface MessageService {
/** /**
* 消息收到确认 * 消息收到确认
* @param message *
* @param channel * @param message 收到的消息
* @param channel  收到的通道
*/ */
void basicAck(Message message, Channel channel); void basicAck(Message message, Channel channel);
} }
...@@ -160,6 +160,12 @@ public class MessageServiceImpl implements MessageService { ...@@ -160,6 +160,12 @@ public class MessageServiceImpl implements MessageService {
return messageVo.getMessageId(); return messageVo.getMessageId();
} }
/**
* 消息收到确认
*
* @param message 收到的消息
* @param channel  收到的通道
*/
@Override @Override
public void basicAck(Message message, Channel channel) { public void basicAck(Message message, Channel channel) {
try { try {
......
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