You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2025/06/11 11:16:00 UTC
(iotdb) 02/02: Remove ThreadLocal for Mqtt Client
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch mqtt_bug
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 19579a3878b323ee60ba22cde11c6d61e62ea0cb
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Wed Jun 11 19:15:32 2025 +0800
Remove ThreadLocal for Mqtt Client
---
.../java/org/apache/iotdb/db/protocol/session/SessionManager.java | 6 ++----
1 file changed, 2 insertions(+), 4 deletions(-)
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/SessionManager.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/SessionManager.java
index 4aa6c9db8a9..d7c5cb6f8be 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/SessionManager.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/SessionManager.java
@@ -360,11 +360,9 @@ public class SessionManager implements SessionManagerMBean {
/**
* this method can be only used in mqtt model. Do not use this method in client-thread model based
* service.
- *
- * @return false if the session has been initialized.
*/
- public boolean registerSessionForMqtt(IClientSession session) {
- return sessions.put(session, placeHolder) == null;
+ public void registerSessionForMqtt(IClientSession session) {
+ sessions.put(session, placeHolder);
}
/** must be called after registerSession()) will mark the session login. */