com.orientechnologies.orient.core.query.live

Class OLiveQueryHookV2.OLiveQueryOps

java.lang.Object

com.orientechnologies.orient.core.query.live.OLiveQueryHookV2.OLiveQueryOps

All Implemented Interfaces:

OCloseable

Enclosing class:

OLiveQueryHookV2

public static class OLiveQueryHookV2.OLiveQueryOps
extends Object
implements OCloseable

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<ODatabaseDocument,List<OLiveQueryHookV2.OLiveQueryOp>>	pendingOps

Constructor Summary

Constructors

Constructor and Description
OLiveQueryOps()

Method Summary

Modifier and Type	Method and Description
void	close() Closes resources inside of call of OStorage#close().
void	enqueue(OLiveQueryHookV2.OLiveQueryOp item)
BlockingQueue<OLiveQueryHookV2.OLiveQueryOp>	getQueue()
OLiveQueryQueueThreadV2	getQueueThread()
Map<Integer,OLiveQueryListenerV2>	getSubscribers()
boolean	hasListeners()
Integer	subscribe(Integer id, OLiveQueryListenerV2 iListener)
void	unsubscribe(Integer id)

Methods inherited from class java.lang.Object

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

Field Detail

pendingOps

protected Map<ODatabaseDocument,List<OLiveQueryHookV2.OLiveQueryOp>> pendingOps

Constructor Detail

OLiveQueryOps

public OLiveQueryOps()

Method Detail

close

public void close()

Description copied from interface: OCloseable

Closes resources inside of call of OStorage#close(). So do not use locks when you call this method or you may have deadlock during storage close. This method is completely house keeping method and plays role of Object#finalize() in case of you need to clean up resources after storage is closed.

Specified by:

close in interface OCloseable

getQueueThread

public OLiveQueryQueueThreadV2 getQueueThread()

getSubscribers

public Map<Integer,OLiveQueryListenerV2> getSubscribers()

getQueue

public BlockingQueue<OLiveQueryHookV2.OLiveQueryOp> getQueue()

enqueue

public void enqueue(OLiveQueryHookV2.OLiveQueryOp item)

subscribe

public Integer subscribe(Integer id,
                         OLiveQueryListenerV2 iListener)

unsubscribe

public void unsubscribe(Integer id)

hasListeners

public boolean hasListeners()