services.moleculer.web.netty

Class NettyServer

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.service.Service

services.moleculer.web.netty.NettyServer

All Implemented Interfaces:

services.moleculer.service.MoleculerLifecycle

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
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 boolean	shutDownThreadPools
protected io.netty.channel.EventLoopGroup	threadGroup
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()
NettyServer(int port)

Method Summary

Modifier and Type	Method and Description
protected io.netty.handler.ssl.SslHandler	createSslHandler(io.netty.channel.Channel ch)
java.lang.String	getAddress()
io.netty.channel.ChannelHandler	getHandler()
java.lang.String	getKeyCertChainFilePath()
java.lang.String	getKeyFilePath()
java.lang.String	getKeyStoreFilePath()
java.lang.String	getKeyStorePassword()
java.lang.String	getKeyStoreType()
int	getPort()
protected io.netty.handler.ssl.SslContext	getSslContext()
io.netty.channel.EventLoopGroup	getThreadGroup()
javax.net.ssl.TrustManagerFactory	getTrustManagerFactory()
int	getWebSocketCleanupSeconds()
boolean	isOpenSslSessionCacheEnabled()
boolean	isShutDownThreadPools()
boolean	isUseSSL()
void	setAddress(java.lang.String address)
void	setHandler(io.netty.channel.ChannelHandler handler)
void	setKeyCertChainFilePath(java.lang.String keyCertChainFilePath)
void	setKeyFilePath(java.lang.String keyFilePath)
void	setKeyStoreFilePath(java.lang.String keyStoreFilePath)
void	setKeyStorePassword(java.lang.String keyStorePassword)
void	setKeyStoreType(java.lang.String keyStoreType)
void	setOpenSslSessionCacheEnabled(boolean openSslSessionCacheEnabled)
void	setPort(int port)
void	setShutDownThreadPools(boolean shutDownThreadPools)
void	setThreadGroup(io.netty.channel.EventLoopGroup singletonGroup)
void	setTrustManagerFactory(javax.net.ssl.TrustManagerFactory trustManagerFactory)
void	setUseSSL(boolean useSSL)
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

threadGroup

protected io.netty.channel.EventLoopGroup threadGroup

handler

protected io.netty.channel.ChannelHandler handler

webSocketCleanupSeconds

protected int webSocketCleanupSeconds

shutDownThreadPools

protected boolean shutDownThreadPools

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

Constructor Detail

NettyServer

public NettyServer()

NettyServer

public NettyServer(int port)

Method Detail

started

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

Specified by:

started in interface services.moleculer.service.MoleculerLifecycle

Overrides:

started in class services.moleculer.service.MoleculerComponent

Throws:

java.lang.Exception

stopped

public void stopped()

Specified by:

stopped in interface services.moleculer.service.MoleculerLifecycle

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)

getPort

public int getPort()

setPort

public void setPort(int port)

isUseSSL

public boolean isUseSSL()

setUseSSL

public void setUseSSL(boolean useSSL)

getTrustManagerFactory

public javax.net.ssl.TrustManagerFactory getTrustManagerFactory()

setTrustManagerFactory

public void setTrustManagerFactory(javax.net.ssl.TrustManagerFactory trustManagerFactory)

getKeyStoreFilePath

public java.lang.String getKeyStoreFilePath()

setKeyStoreFilePath

public void setKeyStoreFilePath(java.lang.String keyStoreFilePath)

getKeyStorePassword

public java.lang.String getKeyStorePassword()

setKeyStorePassword

public void setKeyStorePassword(java.lang.String keyStorePassword)

getKeyStoreType

public java.lang.String getKeyStoreType()

setKeyStoreType

public void setKeyStoreType(java.lang.String keyStoreType)

getKeyCertChainFilePath

public java.lang.String getKeyCertChainFilePath()

setKeyCertChainFilePath

public void setKeyCertChainFilePath(java.lang.String keyCertChainFilePath)

getKeyFilePath

public java.lang.String getKeyFilePath()

setKeyFilePath

public void setKeyFilePath(java.lang.String keyFilePath)

isOpenSslSessionCacheEnabled

public boolean isOpenSslSessionCacheEnabled()

setOpenSslSessionCacheEnabled

public void setOpenSslSessionCacheEnabled(boolean openSslSessionCacheEnabled)

getAddress

public java.lang.String getAddress()

setAddress

public void setAddress(java.lang.String address)

getThreadGroup

public io.netty.channel.EventLoopGroup getThreadGroup()

setThreadGroup

public void setThreadGroup(io.netty.channel.EventLoopGroup singletonGroup)

getHandler

public io.netty.channel.ChannelHandler getHandler()

setHandler

public void setHandler(io.netty.channel.ChannelHandler handler)

isShutDownThreadPools

public boolean isShutDownThreadPools()

setShutDownThreadPools

public void setShutDownThreadPools(boolean shutDownThreadPools)