| Modifier and Type | Field and Description |
|---|---|
| private boolean | |
| private final Map | |
| private final Logger | |
| pack-priv static final int | |
| private final IThreadPoolRetryHandler |
| Access | Constructor and Description |
|---|---|
| pack-priv | ReceivingService(String _namePrefix, ReceivingServiceConfig
configuration _rsCfg)Creates a new instance. |
| Modifier and Type | Method and Description |
|---|---|
| pack-priv int | Returns: retries, if any input was null -1 is returnedrunnable _r)Execute a runnable which handles an error. |
| pack-priv int | Returns: retries, if any input was null -1 is returnedrunnable _r)Execute a runnable which handles a method call. |
| pack-priv int | Returns: retries, if any input was null -1 is returnedrunnable _r)Execute a runnable which handles the return of a method. |
| pack-priv int | Returns: retries, if any input was null -1 is returnedexecutor to use _executor, Runnable runnable _r)Executes a runnable in a given executor. |
| pack-priv int | Returns: retries, if any input was null -1 is returnedrunnable _r)Execute a runnable which handles a signal. |
| pack-priv ExecutorService | Returns: executor or nullexecutor to use _executor)Returns the executor or null. |
| public synchronized void | |
| public synchronized void |
| closed | back to summary |
|---|---|
| private boolean closed | |
| executors | back to summary |
|---|---|
| private final Map<ExecutorNames, ExecutorService> executors | |
| logger | back to summary |
|---|---|
| private final Logger logger | |
| MAX_RETRIES | back to summary |
|---|---|
| pack-priv static final int MAX_RETRIES | |
| retryHandler | back to summary |
|---|---|
| private final IThreadPoolRetryHandler retryHandler | |
| ReceivingService | back to summary |
|---|---|
| pack-priv ReceivingService(String _namePrefix, ReceivingServiceConfig _rsCfg) Creates a new instance.
| |
| execErrorHandler | back to summary |
|---|---|
| pack-priv int execErrorHandler(Runnable _r) Execute a runnable which handles an error.
| |
| execMethodCallHandler | back to summary |
|---|---|
| pack-priv int execMethodCallHandler(Runnable _r) Execute a runnable which handles a method call.
| |
| execMethodReturnHandler | back to summary |
|---|---|
| pack-priv int execMethodReturnHandler(Runnable _r) Execute a runnable which handles the return of a method.
| |
| execOrFail | back to summary |
|---|---|
| pack-priv int execOrFail(ExecutorNames _executor, Runnable _r) Executes a runnable in a given executor.
May retry execution if
| |
| execSignalHandler | back to summary |
|---|---|
| pack-priv int execSignalHandler(Runnable _r) Execute a runnable which handles a signal.
| |
| getExecutor | back to summary |
|---|---|
| pack-priv ExecutorService getExecutor(ExecutorNames _executor) Returns the executor or null.
| |
| shutdown | back to summary |
|---|---|
| public synchronized void shutdown(int _timeout, TimeUnit _unit) Shutdown all executor services waiting up to the given timeout/unit.
| |
| shutdownNow | back to summary |
|---|---|
| public synchronized void shutdownNow() Forcefully stop the executors. | |