Class WebSocketRegistry

java.lang.Object

services.moleculer.web.WebSocketRegistry

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

NettyWebSocketRegistry, ServletWebSocketRegistry

public abstract class WebSocketRegistry
extends Object
implements Runnable

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class Object

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

Field Details

webSocketFilter

protected WebSocketFilter webSocketFilter

registry

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

readLock

protected final ReentrantReadWriteLock.ReadLock readLock

writeLock

protected final ReentrantReadWriteLock.WriteLock writeLock

timer

protected final ScheduledFuture<?> timer

Constructor Details

WebSocketRegistry

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

Method Details

stopped

public void stopped()

register

public void register(String path,
 Endpoint endpoint)

deregister

public void deregister(String path,
 Endpoint endpoint)

send

public void send(String path,
 String message)

run

public void run()

Specified by:

run in interface Runnable

setWebSocketFilter

public void setWebSocketFilter(WebSocketFilter webSocketFilter)

countClients

public Map<String,Integer> countClients()