Package com.bytedesk.core.socket.mqtt

Class MqttConnectionService

java.lang.Object
com.bytedesk.core.socket.mqtt.MqttConnectionService
@Service public class MqttConnectionService extends Object

  • Field Details

    • stringRedisTemplate

      private final org.springframework.data.redis.core.StringRedisTemplate stringRedisTemplate

  • Constructor Details

    • MqttConnectionService

      public MqttConnectionService()

  • Method Details

    • addConnected

      public void addConnected(String clientId)

    • disconnected

      public void disconnected(String clientId)

    • isConnected

      public boolean isConnected(String clientId)

    • cleanExpiredClients

      public void cleanExpiredClients()

    • getConnectedClientIds

      public Set<String> getConnectedClientIds()

    • getConnectedUserUids

      public Set<String> getConnectedUserUids()