public class MoleculerHandler
extends io.netty.channel.SimpleChannelInboundHandler<java.lang.Object>
| Modifier and Type | Field and Description |
|---|---|
protected services.moleculer.ServiceBroker |
broker |
protected ApiGateway |
gateway |
protected io.netty.handler.codec.http.websocketx.WebSocketServerHandshaker |
handshaker |
protected java.lang.String |
path |
protected NettyWebRequest |
req |
protected NettyWebSocketRegistry |
webSocketRegistry |
| Constructor and Description |
|---|
MoleculerHandler(ApiGateway gateway,
services.moleculer.ServiceBroker broker,
NettyWebSocketRegistry nettyWebSocketRegistry) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
channelRead0(io.netty.channel.ChannelHandlerContext ctx,
java.lang.Object request) |
acceptInboundMessage, channelReadchannelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggeredensureNotSharable, handlerAdded, handlerRemoved, isSharableprotected final ApiGateway gateway
protected final services.moleculer.ServiceBroker broker
protected volatile NettyWebRequest req
protected final NettyWebSocketRegistry webSocketRegistry
protected volatile java.lang.String path
protected volatile io.netty.handler.codec.http.websocketx.WebSocketServerHandshaker handshaker
public MoleculerHandler(ApiGateway gateway, services.moleculer.ServiceBroker broker, NettyWebSocketRegistry nettyWebSocketRegistry)