com.orientechnologies.orient.server

Class OPushEventType

java.lang.Object

com.orientechnologies.orient.server.OPushEventType

public class OPushEventType
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentMap<String,Set<WeakReference<ONetworkProtocolBinary>>>	listeners

Constructor Summary

Constructors

Constructor and Description
OPushEventType()

Method Summary

Modifier and Type	Method and Description
void	cleanListeners()
OBinaryPushRequest<?>	getRequest(String database)
void	send(String database, OBinaryPushRequest<?> request, OPushManager pushManager)
void	subscribe(String database, ONetworkProtocolBinary protocol)

Methods inherited from class java.lang.Object

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

Field Detail

listeners

protected final ConcurrentMap<String,Set<WeakReference<ONetworkProtocolBinary>>> listeners

Constructor Detail

OPushEventType

public OPushEventType()

Method Detail

send

public void send(String database,
                 OBinaryPushRequest<?> request,
                 OPushManager pushManager)

getRequest

public OBinaryPushRequest<?> getRequest(String database)

subscribe

public void subscribe(String database,
                      ONetworkProtocolBinary protocol)

cleanListeners

public void cleanListeners()