Skip to content

Y
yzg-util
Commit f389179a authored by yanzg's avatar yanzg
Browse files
Options

处理结果

parent 5ca44d6e
Hide whitespace changes
Inline Side-by-side
Showing with 3 additions and 1 deletion
yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/impl/MqServiceImpl.java
View file @ f389179a
...@@ -146,7 +146,9 @@ public class MqServiceImpl implements MqService, InitializingBean { ...@@ -146,7 +146,9 @@ public class MqServiceImpl implements MqService, InitializingBean {
@Override @Override
public void basicAck(Message message, Channel channel) { public void basicAck(Message message, Channel channel) {
try { try {
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); if (channel != null && message != null) {
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
}
} catch (IOException e) { } catch (IOException e) {
Log.error(MessageServiceImpl.class, e); Log.error(MessageServiceImpl.class, e);
} }
......
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