Package 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	Description
protected Map<ODatabaseDocument,List<OLiveQueryHookV2.OLiveQueryOp>>	pendingOps

Constructor Summary

Constructors

Constructor	Description
OLiveQueryOps()

Method Summary

Modifier and Type	Method	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 Details

pendingOps

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

Constructor Details

OLiveQueryOps

public OLiveQueryOps()

Method Details

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()