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

Class OLiveQueryQueueThread

java.lang.Object

java.lang.Thread

com.orientechnologies.orient.core.query.live.OLiveQueryQueueThread

All Implemented Interfaces:

Runnable

public class OLiveQueryQueueThread
extends Thread

Author:

Luigi Dell'Aquila (l.dellaquila-(at)-orientdb.com)

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
OLiveQueryQueueThread()

Method Summary

Modifier and Type	Method	Description
OLiveQueryQueueThread	clone()
void	enqueue(ORecordOperation item)
boolean	hasListeners()
boolean	hasToken(Integer key)
void	run()
void	stopExecution()
Integer	subscribe(Integer id, OLiveQueryListener iListener)
void	unsubscribe(Integer id)

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Details

OLiveQueryQueueThread

public OLiveQueryQueueThread()

Method Details

clone

public OLiveQueryQueueThread clone()

Overrides:

clone in class Thread

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

stopExecution

public void stopExecution()

enqueue

public void enqueue(ORecordOperation item)

subscribe

public Integer subscribe(Integer id,
 OLiveQueryListener iListener)

unsubscribe

public void unsubscribe(Integer id)

hasListeners

public boolean hasListeners()

hasToken

public boolean hasToken(Integer key)