services.moleculer.web.netty

Class NettyServer

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.service.Service

services.moleculer.web.netty.NettyServer

public class NettyServer
extends services.moleculer.service.Service

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	address
protected io.netty.handler.ssl.SslContext	cachedSslContext
services.moleculer.eventbus.Listener	evt
protected ApiGateway	gateway
protected io.netty.channel.ChannelHandler	handler
protected java.lang.String	keyCertChainFilePath
protected java.lang.String	keyFilePath
protected java.lang.String	keyStoreFilePath
protected java.lang.String	keyStorePassword
protected java.lang.String	keyStoreType
protected boolean	openSslSessionCacheEnabled
protected int	port
protected io.netty.channel.EventLoopGroup	singletonGroup
protected javax.net.ssl.TrustManagerFactory	trustManagerFactory
protected boolean	useSSL
protected int	webSocketCleanupSeconds
protected NettyWebSocketRegistry	webSocketRegistry

Fields inherited from class services.moleculer.service.MoleculerComponent

broker, logger, name

Constructor Summary

Constructors

Constructor and Description
NettyServer()

Method Summary

Modifier and Type	Method and Description
protected io.netty.handler.ssl.SslHandler	createSslHandler(io.netty.channel.Channel ch)
protected io.netty.handler.ssl.SslContext	getSslContext()
int	getWebSocketCleanupSeconds()
void	setWebSocketCleanupSeconds(int webSocketCleanupSeconds)
void	started(services.moleculer.ServiceBroker broker)
void	stopped()

Methods inherited from class services.moleculer.service.MoleculerComponent

getBroker, getLogger, getName

Methods inherited from class java.lang.Object

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

Field Detail

gateway

protected ApiGateway gateway

port

protected int port

address

protected java.lang.String address

singletonGroup

protected io.netty.channel.EventLoopGroup singletonGroup

handler

protected io.netty.channel.ChannelHandler handler

webSocketCleanupSeconds

protected int webSocketCleanupSeconds

useSSL

protected boolean useSSL

trustManagerFactory

protected javax.net.ssl.TrustManagerFactory trustManagerFactory

keyStoreFilePath

protected java.lang.String keyStoreFilePath

keyStorePassword

protected java.lang.String keyStorePassword

keyStoreType

protected java.lang.String keyStoreType

keyCertChainFilePath

protected java.lang.String keyCertChainFilePath

keyFilePath

protected java.lang.String keyFilePath

openSslSessionCacheEnabled

protected boolean openSslSessionCacheEnabled

cachedSslContext

protected io.netty.handler.ssl.SslContext cachedSslContext

webSocketRegistry

protected NettyWebSocketRegistry webSocketRegistry

evt

public services.moleculer.eventbus.Listener evt

Constructor Detail

NettyServer

public NettyServer()

Method Detail

started

public void started(services.moleculer.ServiceBroker broker)
             throws java.lang.Exception

Overrides:

started in class services.moleculer.service.MoleculerComponent

Throws:

java.lang.Exception

stopped

public void stopped()

Overrides:

stopped in class services.moleculer.service.MoleculerComponent

createSslHandler

protected io.netty.handler.ssl.SslHandler createSslHandler(io.netty.channel.Channel ch)
                                                    throws java.lang.Exception

Throws:

java.lang.Exception

getSslContext

protected io.netty.handler.ssl.SslContext getSslContext()
                                                 throws java.lang.Exception

Throws:

java.lang.Exception

getWebSocketCleanupSeconds

public int getWebSocketCleanupSeconds()

setWebSocketCleanupSeconds

public void setWebSocketCleanupSeconds(int webSocketCleanupSeconds)