Package org.freedesktop.dbus.connections

Class ReceivingService

java.lang.Object

org.freedesktop.dbus.connections.ReceivingService

public class ReceivingService
extends Object

Service providing threads for every type of message expected to be received by DBus.

Version:

4.1.0 - 2022-02-02

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	ReceivingService.ExecutorNames	Enum representing different executor services.
static interface	ReceivingService.IThreadPoolRetryHandler	Interface which specifies a handler which will be called when the thread pool throws any exception.

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	closed
private final Map<ReceivingService.ExecutorNames,ExecutorService>	executors
private final org.slf4j.Logger	logger
(package private) static final int	MAX_RETRIES
private final ReceivingService.IThreadPoolRetryHandler	retryHandler

Constructor Summary

Constructors

Constructor	Description
ReceivingService(ReceivingServiceConfig _rsCfg)	Creates a new instance.

Method Summary

Modifier and Type	Method	Description
(package private) int	execErrorHandler(Runnable _r)	Execute a runnable which handles an error.
(package private) int	execMethodCallHandler(Runnable _r)	Execute a runnable which handles a method call.
(package private) int	execMethodReturnHandler(Runnable _r)	Execute a runnable which handles the return of a method.
(package private) int	execOrFail(ReceivingService.ExecutorNames _executor, Runnable _r)	Executes a runnable in a given executor.
(package private) int	execSignalHandler(Runnable _r)	Execute a runnable which handles a signal.
(package private) ExecutorService	getExecutor(ReceivingService.ExecutorNames _executor)	Returns the executor or null.
void	shutdown(int _timeout, TimeUnit _unit)	Shutdown all executor services waiting up to the given timeout/unit.
void	shutdownNow()	Forcefully stop the executors.

Methods inherited from class java.lang.Object

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

Field Details

MAX_RETRIES

static final int MAX_RETRIES

See Also:

• Constant Field Values

logger

private final org.slf4j.Logger logger

closed

private boolean closed

executors

private final Map<ReceivingService.ExecutorNames,ExecutorService> executors

retryHandler

private final ReceivingService.IThreadPoolRetryHandler retryHandler

Constructor Details

ReceivingService

ReceivingService(ReceivingServiceConfig _rsCfg)

Creates a new instance.

Parameters:

_rsCfg - configuration

Method Details

execSignalHandler

int execSignalHandler(Runnable _r)

Execute a runnable which handles a signal.

Parameters:

_r - runnable

Returns:

retries, if any input was null -1 is returned

execErrorHandler

int execErrorHandler(Runnable _r)

Execute a runnable which handles an error.

Parameters:

_r - runnable

Returns:

retries, if any input was null -1 is returned

execMethodCallHandler

int execMethodCallHandler(Runnable _r)

Execute a runnable which handles a method call.

Parameters:

_r - runnable

Returns:

retries, if any input was null -1 is returned

execMethodReturnHandler

int execMethodReturnHandler(Runnable _r)

Execute a runnable which handles the return of a method.

Parameters:

_r - runnable

Returns:

retries, if any input was null -1 is returned

execOrFail

int execOrFail(ReceivingService.ExecutorNames _executor,
 Runnable _r)

Executes a runnable in a given executor. May retry execution if ExecutorService has thrown an exception and retry handler allows re-processing. When re-processing fails for 50 or more retries, an error will be logged and the runnable will not be executed.

Parameters:

_executor - executor to use

_r - runnable

Returns:

retries, if any input was null -1 is returned

getExecutor

ExecutorService getExecutor(ReceivingService.ExecutorNames _executor)

Returns the executor or null.

Parameters:

_executor - executor to use

Returns:

executor or null

shutdown

public void shutdown(int _timeout,
 TimeUnit _unit)

Shutdown all executor services waiting up to the given timeout/unit.

Parameters:

_timeout - timeout

_unit - time unit

shutdownNow

public void shutdownNow()

Forcefully stop the executors.