Package com.bytedesk.core.socket.mqtt.server

Class MqttWebSocketServer

java.lang.Object

com.bytedesk.core.socket.mqtt.server.MqttWebSocketServer

@Component
public class MqttWebSocketServer
extends Object

encrypt/security through nginx proxy

Author:

bytedesk.com on 2019-07-23

Field Summary

Fields

Modifier and Type	Field	Description
private io.netty.channel.EventLoopGroup	childEventLoopGroup
private MqttProperties	mqttProperties
private io.netty.channel.EventLoopGroup	parentEventLoopGroup
private ProtocolProcess	protocolProcess
private io.netty.channel.Channel	serverChannel

Constructor Summary

Constructors

Constructor	Description
MqttWebSocketServer()

Method Summary

Modifier and Type	Method	Description
void	init()
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Details

mqttProperties

@Autowired
private MqttProperties mqttProperties

protocolProcess

@Autowired
private ProtocolProcess protocolProcess

serverChannel

private io.netty.channel.Channel serverChannel

parentEventLoopGroup

private io.netty.channel.EventLoopGroup parentEventLoopGroup

childEventLoopGroup

private io.netty.channel.EventLoopGroup childEventLoopGroup

Constructor Details

MqttWebSocketServer

public MqttWebSocketServer()

Method Details

init

@PostConstruct
public void init()
          throws Exception

Throws:

Exception

shutdown

@PreDestroy
public void shutdown()
              throws InterruptedException

Throws:

InterruptedException