From 5187e63329f6b090de8abf2bf9fcf65784d9fda8 Mon Sep 17 00:00:00 2001 From: "heavyrain.lee" Date: Fri, 6 Mar 2020 08:11:17 +0800 Subject: [PATCH] =?UTF-8?q?=E9=80=8F=E4=BC=A0=E6=B6=88=E6=81=AF=E5=A6=82?= =?UTF-8?q?=E6=9E=9C=E6=98=AF=E8=B6=85=E8=BF=87=E4=B8=80=E5=B0=8F=E6=97=B6?= =?UTF-8?q?=E4=B8=8D=E5=9C=A8=E7=BA=BF=E5=B0=B1=E4=B8=8D=E9=9C=80=E8=A6=81?= =?UTF-8?q?=E5=8F=91=E9=80=81=E4=BA=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/io/moquette/spi/impl/MessagesPublisher.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java b/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java index 0f787030..4c181030 100755 --- a/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java +++ b/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java @@ -344,6 +344,10 @@ public class MessagesPublisher { Collection sessions = m_sessionsStore.sessionForUser(user); for (Session targetSession : sessions) { + if(System.currentTimeMillis() - targetSession.getLastActiveTime() > 60 * 60 * 1000) { + continue; + } + if (targetSession.getClientID() == null) { continue; }