Class EnterprisePersistentQueryHandle
java.lang.Object
com.illumon.iris.controller.handle.PersistentQueryHandleBase
com.illumon.iris.controller.handle.EnterprisePersistentQueryHandle
- All Implemented Interfaces:
PersistentQueryHandle
A Handle to a Persistent Query backed by an Enterprise worker.
-
Field Summary
Fields inherited from class com.illumon.iris.controller.handle.PersistentQueryHandleBase
config, configurationType, dispatcherConnectionHandler, encryption, executorService, groupProvider, loader, log, logPrefix, state, stateLock, workerProcessInfoId, workerRequestHandle
-
Constructor Summary
ConstructorsConstructorDescriptionEnterprisePersistentQueryHandle
(com.fishlib.io.logger.Logger log, Object queryHandleContext) Create a new Handle for an enterprise worker. -
Method Summary
Modifier and TypeMethodDescriptionprotected WorkerHandle
createWorkerHandle
(RemoteProcessingRequest request, QueryDispatcherConnection dispatcherConnection) protected boolean
onDispatcherConnected
(QueryDispatcherConnection dispatcherConnection) protected void
Methods inherited from class com.illumon.iris.controller.handle.PersistentQueryHandleBase
checkQueryTerminatingOrTerminal, ensureShutdown, errorLog, getScriptCode, getState, getStateLock, getVersion, getWorkerHandle, infoLog, maybeSetTerminalStatus, onError, onFailure, onFailure, publishState, restore, setReplicaSlot, shutdown, start, warnLog
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface com.illumon.iris.controller.handle.PersistentQueryHandle
canTryToRestore, restore
-
Constructor Details
-
EnterprisePersistentQueryHandle
public EnterprisePersistentQueryHandle(@NotNull com.fishlib.io.logger.Logger log, @NotNull Object queryHandleContext) Create a new Handle for an enterprise worker.- Parameters:
log
- the log.queryHandleContext
- A context object containing the required parameters for this object.
-
-
Method Details
-
onStartRequested
protected void onStartRequested()- Specified by:
onStartRequested
in classPersistentQueryHandleBase
-
onDispatcherConnected
- Specified by:
onDispatcherConnected
in classPersistentQueryHandleBase
-
createWorkerHandle
protected WorkerHandle createWorkerHandle(RemoteProcessingRequest request, QueryDispatcherConnection dispatcherConnection) - Specified by:
createWorkerHandle
in classPersistentQueryHandleBase
-