Package com.bytedesk.core.socket.mqtt.protocol

Class ProtocolProcess

java.lang.Object

com.bytedesk.core.socket.mqtt.protocol.ProtocolProcess

@Component
public class ProtocolProcess
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private Connect	connect
private DisConnect	disConnect
private IMessageSendService	messageSendService
private MqttService	mqService
private MqttAuthService	mqttAuthService
private MqttConnectionService	mqttConnectionService
private MqttMessageIdService	mqttMessageIdService
private MqttSessionService	mqttSessionStoreService
private PingReq	pingReq
private PubAck	pubAck
private PubComp	pubComp
private Publish	publish
private PubRec	pubRec
private PubRel	pubRel
private Subscribe	subscribe
private UnSubscribe	unSubscribe

Constructor Summary

Constructors

Constructor	Description
ProtocolProcess()

Method Summary

Modifier and Type	Method	Description
Connect	connect()
DisConnect	disConnect()
PingReq	pingReq()
PubAck	pubAck()
PubComp	pubComp()
Publish	publish()
PubRec	pubRec()
PubRel	pubRel()
Subscribe	subscribe()
UnSubscribe	unSubscribe()

Methods inherited from class java.lang.Object

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

Field Details

mqttSessionStoreService

@Autowired
private MqttSessionService mqttSessionStoreService

mqttAuthService

@Autowired
private MqttAuthService mqttAuthService

mqttMessageIdService

@Autowired
private MqttMessageIdService mqttMessageIdService

mqService

@Autowired
private MqttService mqService

messageSendService

@Autowired
private IMessageSendService messageSendService

mqttConnectionService

@Autowired
private MqttConnectionService mqttConnectionService

connect

private Connect connect

subscribe

private Subscribe subscribe

unSubscribe

private UnSubscribe unSubscribe

publish

private Publish publish

disConnect

private DisConnect disConnect

pingReq

private PingReq pingReq

pubRel

private PubRel pubRel

pubAck

private PubAck pubAck

pubRec

private PubRec pubRec

pubComp

private PubComp pubComp

Constructor Details

ProtocolProcess

public ProtocolProcess()

Method Details

connect

public Connect connect()

subscribe

public Subscribe subscribe()

unSubscribe

public UnSubscribe unSubscribe()

publish

public Publish publish()

disConnect

public DisConnect disConnect()

pingReq

public PingReq pingReq()

pubRel

public PubRel pubRel()

pubAck

public PubAck pubAck()

pubRec

public PubRec pubRec()

pubComp

public PubComp pubComp()