org.rvpf.forwarder

Class ForwarderServiceAppImpl

Object

ServiceAppImpl

ForwarderServiceAppImpl

All Implemented Interfaces:

ServiceApp

public final class ForwarderServiceAppImpl
extends ServiceAppImpl

Forwarder service application implementation.

Field Summary

Fields

Modifier and Type	Field and Description
static String	MODULE_CLASS_PROPERTY The class of the module to activate.
static String	MODULE_PROPERTIES Properties used to define a forwarder module.

Fields inherited from class ServiceAppImpl

SERVICE_APP_PROPERTIES

Constructor Summary

Constructors

Constructor and Description
ForwarderServiceAppImpl()

Method Summary

Modifier and Type	Method and Description
int	getOutputsSize() Gets the outputs size.
boolean	onSignal(Signal signal) Called when a signal has been received.
boolean	output(Serializable[] messages) Output messages.
boolean	setUp(Service service) Sets up the application.
void	start() Starts the application.
void	stop() Stops the application.
void	tearDown() Tears down the application.

Methods inherited from class ServiceAppImpl

createStats, fail, getConfig, getConfigProperties, getDataDir, getJoinTimeout, getProperties, getService, getSourceUUID, getThisLogger, getTimer, onAlert, onEvent, onServiceNotAvailableException, onServicesNotReady, onServicesReady

Methods inherited from class Object

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

Field Detail

MODULE_CLASS_PROPERTY

public static final String MODULE_CLASS_PROPERTY

The class of the module to activate.

See Also:

Constant Field Values

MODULE_PROPERTIES

public static final String MODULE_PROPERTIES

Properties used to define a forwarder module.

See Also:

Constant Field Values

Constructor Detail

ForwarderServiceAppImpl

public ForwarderServiceAppImpl()

Method Detail

getOutputsSize

public int getOutputsSize()

Gets the outputs size.

Returns:

The outputs size.

onSignal

public boolean onSignal(Signal signal)

Called when a signal has been received.

Caution: this is called while synchronized on the service.

Specified by:

onSignal in interface ServiceApp

Overrides:

onSignal in class ServiceAppImpl

Parameters:

signal - The signal.

Returns:

False to inhibit further actions on the signal.

output

@CheckReturnValue
public boolean output(@Nonnull
                                         Serializable[] messages)
                                  throws InterruptedException,
                                         ServiceNotAvailableException

Output messages.

Parameters:

messages - The messages.

Returns:

True on success.

Throws:

InterruptedException - When the service is stopped.

ServiceNotAvailableException - When the service is not available.

setUp

public boolean setUp(Service service)

Sets up the application.

Overidden as needed.

Called by the framework and by overriding classes at the beginning of the override.

Specified by:

setUp in interface ServiceApp

Overrides:

setUp in class ServiceAppImpl

Parameters:

service - The service holding this application.

Returns:

True on success.

start

public void start()

Starts the application.

Overidden as needed by the application.

Called by the framework.

Should return only when the application is started.

Specified by:

start in interface ServiceApp

Overrides:

start in class ServiceAppImpl

stop

public void stop()

Stops the application.

Overidden as needed by the application.

Called by the framework.

Specified by:

stop in interface ServiceApp

Overrides:

stop in class ServiceAppImpl

tearDown

public void tearDown()

Tears down the application.

Overidden as needed by the application.

Called by the framework and by overriding classes at the end of the override.

Specified by:

tearDown in interface ServiceApp

Overrides:

tearDown in class ServiceAppImpl