services.moleculer.web

Class WebSocketRegistry

java.lang.Object

services.moleculer.web.WebSocketRegistry

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

NettyWebSocketRegistry, ServletWebSocketRegistry

public abstract class WebSocketRegistry
extends java.lang.Object
implements java.lang.Runnable

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock	readLock
protected java.util.HashMap<java.lang.String,services.moleculer.web.WebSocketRegistry.EndpointSet>	registry
protected java.util.concurrent.ScheduledFuture<?>	timer
protected WebSocketFilter	webSocketFilter
protected java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock	writeLock

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.String,java.lang.Integer>	countClients()
void	deregister(java.lang.String path, Endpoint endpoint)
void	register(java.lang.String path, Endpoint endpoint)
void	run()
void	send(java.lang.String path, java.lang.String message)
void	setWebSocketFilter(WebSocketFilter webSocketFilter)
void	stopped()

Methods inherited from class java.lang.Object

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

Field Detail

webSocketFilter

protected WebSocketFilter webSocketFilter

registry

protected java.util.HashMap<java.lang.String,services.moleculer.web.WebSocketRegistry.EndpointSet> registry

readLock

protected final java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock readLock

writeLock

protected final java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock writeLock

timer

protected final java.util.concurrent.ScheduledFuture<?> timer

Constructor Detail

WebSocketRegistry

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

Method Detail

stopped

public void stopped()

register

public void register(java.lang.String path,
                     Endpoint endpoint)

deregister

public void deregister(java.lang.String path,
                       Endpoint endpoint)

send

public void send(java.lang.String path,
                 java.lang.String message)

run

public void run()

Specified by:

run in interface java.lang.Runnable

setWebSocketFilter

public void setWebSocketFilter(WebSocketFilter webSocketFilter)

countClients

public java.util.Map<java.lang.String,java.lang.Integer> countClients()