Package deltix.qsrv.hf.pub.util

Class LiveCursorWatcherEx

java.lang.Object

java.lang.Thread

deltix.qsrv.hf.pub.util.LiveCursorWatcher

deltix.qsrv.hf.pub.util.LiveCursorWatcherEx

All Implemented Interfaces:

deltix.util.lang.Disposable, java.io.Closeable, java.lang.AutoCloseable, java.lang.Runnable

public final class LiveCursorWatcherEx
extends LiveCursorWatcher

Similar to LiveCursorWatcher but automatically closes cursor. Usage example:

 LiveCursorWatcherEx watcher = LiveCursorWatcherEx.start ("my-stream", new MessageListener () { ... });
 ...
 watcher.close();
 

Nested Class Summary

Nested classes/interfaces inherited from class deltix.qsrv.hf.pub.util.LiveCursorWatcher

LiveCursorWatcher.MessageListener

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

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class deltix.qsrv.hf.pub.util.LiveCursorWatcher

cursor

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Method Summary

Modifier and Type	Method	Description
void	close()
static LiveCursorWatcherEx	start(DXTickDB tickDB, java.lang.String streamKey, LiveCursorWatcher.MessageListener listener)

Methods inherited from class deltix.qsrv.hf.pub.util.LiveCursorWatcher

interrupt, run

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, 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

Method Detail

start

public static LiveCursorWatcherEx start(DXTickDB tickDB,
                                        java.lang.String streamKey,
                                        LiveCursorWatcher.MessageListener listener)

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface deltix.util.lang.Disposable

Overrides:

close in class LiveCursorWatcher