Class ORemoteClientPushThread
java.lang.Object
java.lang.Thread
com.orientechnologies.orient.client.remote.ORemoteClientPushThread
- All Implemented Interfaces:
Runnable
Created by tglman on 11/01/17.
-
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
ConstructorsConstructorDescriptionORemoteClientPushThread(ORemotePushHandler storage, String host, int retryDelay, long requestTimeout) -
Method Summary
Modifier and TypeMethodDescriptionvoidhandleException(Throwable throwable) voidrun()voidshutdown()<T extends OBinaryResponse>
Tsubscribe(OBinaryRequest<T> request, ORemoteClientSession session) 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, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
Constructor Details
-
ORemoteClientPushThread
public ORemoteClientPushThread(ORemotePushHandler storage, String host, int retryDelay, long requestTimeout)
-
-
Method Details
-
handleException
-
run
public void run() -
subscribe
public <T extends OBinaryResponse> T subscribe(OBinaryRequest<T> request, ORemoteClientSession session) -
shutdown
public void shutdown()
-