org.rvpf.processor

Class ProcessorServiceAppImpl

Object

ServiceAppImpl

MetadataServiceAppImpl

ProcessorServiceAppImpl

All Implemented Interfaces:

Processor, ServiceApp, MetadataServiceApp, ServiceThread.Target

public final class ProcessorServiceAppImpl
extends MetadataServiceAppImpl
implements ServiceThread.Target, Processor

Processor service application implementation.

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_NAME Default processor name.
static ClassDef	DEFAULT_RECEPTIONIST_CLASS_DEF Default receptionist class.
static String	NAME_PROPERTY Name property.
static String	PROCESSOR_PROPERTIES Processor properties.
static String	RECEPTIONIST_CLASS_PROPERTY Used to specify an alternative to the SOM receptionist.

Fields inherited from class ServiceAppImpl

SERVICE_APP_PROPERTIES

Constructor Summary

Constructors

Constructor and Description
ProcessorServiceAppImpl()

Method Summary

Modifier and Type	Method and Description
ServiceStats	createStats(StatsOwner statsOwner) Creates a stats instance.
Optional<String>	getEntityName() Gets the entity name.
boolean	onNewMetadata(Metadata metadata) Called on new metadata.
void	onServicesNotReady() Called when some services are not ready.
Optional<Collection<PointValue>>	process(Collection<PointValue> pointValues) Processes point values.
void	run() Runs.
boolean	setUp(MetadataService 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 MetadataServiceAppImpl

getMetadata, getService, loadMetadata, setUp

Methods inherited from class ServiceAppImpl

fail, getConfig, getConfigProperties, getDataDir, getJoinTimeout, getProperties, getSourceUUID, getThisLogger, getTimer, onAlert, onEvent, onServiceNotAvailableException, onServicesReady, onSignal

Methods inherited from class Object

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

Methods inherited from interface ServiceApp

onAlert, onEvent, onServicesReady, onSignal

Field Detail

DEFAULT_NAME

public static final String DEFAULT_NAME

Default processor name.

See Also:

Constant Field Values

NAME_PROPERTY

public static final String NAME_PROPERTY

Name property.

See Also:

Constant Field Values

PROCESSOR_PROPERTIES

public static final String PROCESSOR_PROPERTIES

Processor properties.

See Also:

Constant Field Values

DEFAULT_RECEPTIONIST_CLASS_DEF

public static final ClassDef DEFAULT_RECEPTIONIST_CLASS_DEF

Default receptionist class.

RECEPTIONIST_CLASS_PROPERTY

public static final String RECEPTIONIST_CLASS_PROPERTY

Used to specify an alternative to the SOM receptionist.

See Also:

Constant Field Values

Constructor Detail

ProcessorServiceAppImpl

public ProcessorServiceAppImpl()

Method Detail

createStats

public ServiceStats createStats(StatsOwner statsOwner)

Creates a stats instance.

Specified by:

createStats in interface ServiceApp

Overrides:

createStats in class ServiceAppImpl

Parameters:

statsOwner - The stats owner.

Returns:

The stats instance.

getEntityName

public Optional<String> getEntityName()

Gets the entity name.

Specified by:

getEntityName in interface MetadataServiceApp

Overrides:

getEntityName in class MetadataServiceAppImpl

Returns:

The optional entity name.

onNewMetadata

public boolean onNewMetadata(Metadata metadata)

Called on new metadata.

Overidden as needed.

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

Specified by:

onNewMetadata in interface MetadataServiceApp

Overrides:

onNewMetadata in class MetadataServiceAppImpl

Parameters:

metadata - The new metadata.

Returns:

False to reject the metadata.

onServicesNotReady

public void onServicesNotReady()

Called when some services are not ready.

This is called by the pending actions processing when it not known if all registered services are ready. This may be used by a service thread to trigger some state refresh when the pending actions processing is completed; at that time, all the registered services will be ready.

Specified by:

onServicesNotReady in interface ServiceApp

Overrides:

onServicesNotReady in class ServiceAppImpl

process

public Optional<Collection<PointValue>> process(Collection<PointValue> pointValues)
                                         throws InterruptedException,
                                                ServiceNotAvailableException

Processes point values.

Specified by:

process in interface Processor

Parameters:

pointValues - The input point values.

Returns:

The output point values (empty to retry smaller).

Throws:

InterruptedException - When the service is stopped.

ServiceNotAvailableException - When the service is not available.

run

public void run()
         throws InterruptedException

Runs.

Similar to same in Runnable but may throw exceptions.

Specified by:

run in interface ServiceThread.Target

Throws:

InterruptedException

setUp

public boolean setUp(MetadataService 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 MetadataServiceApp

Overrides:

setUp in class MetadataServiceAppImpl

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