Package org.ovirt.vdsm.jsonrpc.client.reactors

Class ReactorFactory

java.lang.Object

org.ovirt.vdsm.jsonrpc.client.reactors.ReactorFactory

public class ReactorFactory
extends Object

Factory class which provide single instance of Reactors or ResponseWorker within single loading scope.

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	EVENT_TIMEOUT_IN_HOURS	Default timeout to clean up unprocessed events, which are in the queue more than this timeout.
private static SSLStompReactor	sslStompReactor
private static StompReactor	stompReactor
private static ResponseWorker	worker

Constructor Summary

Constructors

Constructor	Description
ReactorFactory()

Method Summary

Modifier and Type	Method	Description
static Reactor	getReactor(ManagerProvider provider, ReactorType type)	Provides instance of Reactor based on ManagerProvider availability and type provided.
private static Reactor	getSslStompReactor(ManagerProvider provider)
private static Reactor	getStompReactor(ManagerProvider provider)
static ResponseWorker	getWorker(int parallelism)
static ResponseWorker	getWorker(int parallelism, int eventTimeoutInHours)

Methods inherited from class java.lang.Object

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

Field Details

EVENT_TIMEOUT_IN_HOURS

private static final int EVENT_TIMEOUT_IN_HOURS

Default timeout to clean up unprocessed events, which are in the queue more than this timeout. The value should be passed from oVirt engine 4.3+, but we need to keep default value to preserve backward compatibility with 4.2.

See Also:

• Constant Field Values

stompReactor

private static volatile StompReactor stompReactor

sslStompReactor

private static volatile SSLStompReactor sslStompReactor

worker

private static volatile ResponseWorker worker

Constructor Details

ReactorFactory

public ReactorFactory()

Method Details

getReactor

public static Reactor getReactor(ManagerProvider provider,
 ReactorType type)
                          throws ClientConnectionException

Provides instance of Reactor based on ManagerProvider availability and type provided.

Parameters:

provider - Provides ability to get SSL context.

type - ReactorType which will be created.

Returns:

NioReactor reactor when provider is null or SSLReactor.

Throws:

ClientConnectionException - when unexpected type value is provided or issue with constucting selector.

getWorker

public static ResponseWorker getWorker(int parallelism)

Parameters:

parallelism - the parallelism level using for event processing.

Returns:

Single instance of ResponseWorker.

getWorker

public static ResponseWorker getWorker(int parallelism,
 int eventTimeoutInHours)

Parameters:

parallelism - the parallelism level using for event processing.

eventTimeoutInHours - the timeout after which the events are purged from the queue.

Returns:

Single instance of ResponseWorker.

getStompReactor

private static Reactor getStompReactor(ManagerProvider provider)
                                throws ClientConnectionException

Throws:

ClientConnectionException

getSslStompReactor

private static Reactor getSslStompReactor(ManagerProvider provider)
                                   throws ClientConnectionException

Throws:

ClientConnectionException