From 1a406e3e206af1ab7e38042548a085b078b6ca09 Mon Sep 17 00:00:00 2001 From: kaiyu <404897439@qq.com> Date: Tue, 15 Dec 2020 14:34:26 +0800 Subject: [PATCH] 增加websocket单位 --- src/main/java/com/moral/util/RabbitMQUtils.java | 4 ++-- 1 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/moral/util/RabbitMQUtils.java b/src/main/java/com/moral/util/RabbitMQUtils.java index ab031ec..115f4f1 100644 --- a/src/main/java/com/moral/util/RabbitMQUtils.java +++ b/src/main/java/com/moral/util/RabbitMQUtils.java @@ -27,9 +27,9 @@ public static void closeConnectionChannel(Connection connection, Channel channel){ try{ - if(channel!=null) + if(channel!=null&&channel.isOpen()) channel.close(); - if(connection!=null) + if(connection!=null&&connection.isOpen()) connection.close(); }catch (Exception e){ e.printStackTrace(); -- Gitblit v1.8.0