Package com.bytedesk.core.socket.mqtt

Class MqttRestController

java.lang.Object

com.bytedesk.core.socket.mqtt.MqttRestController

@RestController
@RequestMapping("/mqtt/api/v1")
public class MqttRestController
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final MqttConnectionService	mqttConnectionService
private final MqttSessionService	mqttSessionService

Constructor Summary

Constructors

Constructor	Description
MqttRestController()

Method Summary

Modifier and Type	Method	Description
org.springframework.http.ResponseEntity<?>	getSessionClients()	get clientIds that has session in the local mqtt server http://127.0.0.1:9003/mqtt/api/v1/session/clients
org.springframework.http.ResponseEntity<?>	isConnectedClients()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

mqttSessionService

private final MqttSessionService mqttSessionService

mqttConnectionService

private final MqttConnectionService mqttConnectionService

Constructor Details

MqttRestController

public MqttRestController()

Method Details

getSessionClients

@GetMapping("/session/clients")
public org.springframework.http.ResponseEntity<?> getSessionClients()

get clientIds that has session in the local mqtt server http://127.0.0.1:9003/mqtt/api/v1/session/clients

Returns:

isConnectedClients

@GetMapping("/connected/clients")
public org.springframework.http.ResponseEntity<?> isConnectedClients()