services.moleculer.web.netty

Class NettyWebSocketRegistry

java.lang.Object

services.moleculer.web.WebSocketRegistry

services.moleculer.web.netty.NettyWebSocketRegistry

All Implemented Interfaces:

java.lang.Runnable

public class NettyWebSocketRegistry
extends WebSocketRegistry

Field Summary

Fields inherited from class services.moleculer.web.WebSocketRegistry

readLock, registry, timer, webSocketFilter, writeLock

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	deregister(java.lang.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, java.lang.String path)
void	register(java.lang.String path, io.netty.channel.ChannelHandlerContext ctx)
protected Endpoint	toEnpoint(io.netty.channel.ChannelHandlerContext ctx)

Methods inherited from class services.moleculer.web.WebSocketRegistry

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

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyWebSocketRegistry

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

Method Detail

register

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

deregister

public void deregister(java.lang.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,
                                     java.lang.String path)
                              throws java.io.IOException

Throws:

java.io.IOException