Class NettyWebSocketRegistry

java.lang.Object

services.moleculer.web.WebSocketRegistry

services.moleculer.web.netty.NettyWebSocketRegistry

All Implemented Interfaces:

Runnable

public class NettyWebSocketRegistry
extends WebSocketRegistry

Field Summary

Fields inherited from class WebSocketRegistry

readLock, registry, timer, webSocketFilter, writeLock

Constructor Summary

Constructors

Constructor	Description
NettyWebSocketRegistry(services.moleculer.ServiceBroker broker, long cleanupSeconds)

Method Summary

Modifier and Type	Method	Description
void	deregister(String path, io.netty.channel.ChannelHandlerContext ctx)
io.datatree.Promise	isRefused(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http.HttpRequest req, io.netty.handler.codec.http.HttpHeaders headers, services.moleculer.ServiceBroker broker, String path)
void	register(String path, io.netty.channel.ChannelHandlerContext ctx)
protected Endpoint	toEnpoint(io.netty.channel.ChannelHandlerContext ctx)

Methods inherited from class WebSocketRegistry

countClients, deregister, register, run, send, setWebSocketFilter, stopped

Methods inherited from class Object

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

Constructor Details

NettyWebSocketRegistry

public NettyWebSocketRegistry(services.moleculer.ServiceBroker broker,
 long cleanupSeconds)

Method Details

register

public void register(String path,
 io.netty.channel.ChannelHandlerContext ctx)

deregister

public void deregister(String path,
 io.netty.channel.ChannelHandlerContext ctx)

toEnpoint

protected Endpoint toEnpoint(io.netty.channel.ChannelHandlerContext ctx)

isRefused

public io.datatree.Promise isRefused(io.netty.channel.ChannelHandlerContext ctx,
 io.netty.handler.codec.http.HttpRequest req,
 io.netty.handler.codec.http.HttpHeaders headers,
 services.moleculer.ServiceBroker broker,
 String path)
                              throws IOException

Throws:

IOException