Package com.orientechnologies.orient.core.query.live

Class OLiveQueryOps

java.lang.Object

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

All Implemented Interfaces:

OCloseable

public class OLiveQueryOps
extends Object
implements OCloseable

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
OLiveQueryOps()

Method Summary

Modifier and Type	Method	Description
void	addOp(OLiveQueryOp result, ODatabaseDocument db)
void	close()	Closes resources inside of call of OStorage#close().
void	enqueue(OLiveQueryOp item)
void	enqueueForDb(ODatabaseDocument database)
BlockingQueue<OLiveQueryOp>	getQueue()
OLiveQueryQueueThreadV2	getQueueThread()
Map<Integer,OLiveQueryListenerV2>	getSubscribers()
boolean	hasListeners()
void	removeForDb(ODatabaseDocument database)
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<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<OLiveQueryOp> getQueue()

enqueue

public void enqueue(OLiveQueryOp item)

subscribe

public Integer subscribe(Integer id,
 OLiveQueryListenerV2 iListener)

unsubscribe

public void unsubscribe(Integer id)

enqueueForDb

public void enqueueForDb(ODatabaseDocument database)

hasListeners

public boolean hasListeners()

removeForDb

public void removeForDb(ODatabaseDocument database)

addOp

public void addOp(OLiveQueryOp result,
 ODatabaseDocument db)