oracle.pgx.api.admin

Class AbstractEmbeddedControl<PgxConfigType extends AbstractEngineConfig>

java.lang.Object

oracle.pgx.api.admin.AbstractControl

oracle.pgx.api.admin.AbstractEmbeddedControl<PgxConfigType>

All Implemented Interfaces:

Control

public abstract class AbstractEmbeddedControl<PgxConfigType extends AbstractEngineConfig>
extends oracle.pgx.api.admin.AbstractControl

A common implementation for Ctrl (of SM) and DistControl (of DIST).

Field Summary

Fields inherited from class oracle.pgx.api.admin.AbstractControl

LOG_MESSAGE_NO_CONFIG_FOUND

Fields inherited from interface oracle.pgx.api.admin.Control

ALL_PATHS_PROXY_MAP_KEY, COLLECTION_PROXY_MAP_KEY, COMPONENTS_PROXY_MAP_KEY, FUTURE_MAP_KEY, KEYSTORE_PATH_SYSTEM_PROPERTY, KEYSTORE_SECRET_SYSTEM_PROPERTY, MAP_PROXY_MAP_KEY, PGQL_RESULTS_KEY, PGX_CONFIG_FILE_SYSTEM_PROPERTY, PROPERTY_PROXY_MAP_KEY, SERVER_CONFIG_FILE_NAME

Constructor Summary

Constructors

Constructor and Description
AbstractEmbeddedControl()

Method Summary

Modifier and Type	Method and Description
PgxFuture<java.lang.Boolean>	isRunning() Check if the engine is currently up
PgxFuture<java.lang.Void>	shutdownNow() forces the engine to stop and clean up resources.
void	startImplicitlyIfNotRunning()
void	throwIfNotRunning()
PgxFuture<java.lang.Void>	throwIfNotRunningAsync()

Methods inherited from class oracle.pgx.api.admin.AbstractControl

runOnCallerThread, shutdownNowIfRunning, start, start, start, start, updatePgxConfig, updatePgxConfig

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface oracle.pgx.api.admin.Control

addPinnedGraph, addUserData, demotePinnedGraph, freeCachedMemory, freeCachedMemory, getExtendedVersion, getPgxConfig, getPgxConfigObject, getServerState, getUserData, getVersion, joinMachine, killSession, resizePool, shutdown, start, start, updatePgxConfig, updatePgxConfig

Constructor Detail

AbstractEmbeddedControl

public AbstractEmbeddedControl()

Method Detail

isRunning

public PgxFuture<java.lang.Boolean> isRunning()

Description copied from interface: Control

Check if the engine is currently up

Returns:

true if engine is currently running, false otherwise

shutdownNow

public PgxFuture<java.lang.Void> shutdownNow()

Description copied from interface: Control

forces the engine to stop and clean up resources. Currently running tasks are interrupted. New incoming requests get rejected.

Throws an exception when current tasks didn't finish after a short grace period.

startImplicitlyIfNotRunning

public void startImplicitlyIfNotRunning()
                                 throws java.util.concurrent.ExecutionException,
                                        java.lang.InterruptedException

Throws:

java.util.concurrent.ExecutionException

java.lang.InterruptedException

throwIfNotRunning

public void throwIfNotRunning()

throwIfNotRunningAsync

public PgxFuture<java.lang.Void> throwIfNotRunningAsync()