org.rvpf.store.server.sink

Class SinkServiceAppImpl

Object

ServiceAppImpl

MetadataServiceAppImpl

StoreServiceAppImpl

SinkServiceAppImpl

All Implemented Interfaces:

ServiceApp, MetadataServiceApp, ServiceThread.Target, SinkServiceApp, StoreServiceApp

public class SinkServiceAppImpl
extends StoreServiceAppImpl
implements SinkServiceApp

Sink app implementation.

Field Summary

Fields

Modifier and Type	Field and Description
static ClassDef	DEFAULT_SINK_MODULE Default sink module.
static String	PROCESSOR_PROPERTY Processor property.
static String	SERVER_PROPERTIES Server properties.
static String	SINK_MODULE_CLASS_PROPERTY Specifies a class implementing the sink module interface.

Fields inherited from class StoreServiceAppImpl

BACK_END_LIMIT_PROPERTY, DEFAULT_NOTIFIER_CLASS, DEFAULT_POLATOR, DEFAULT_REPLICATOR, DEFAULT_RESPONSE_LIMIT, DEFAULT_SERVER_PROPERTIES, DEFAULT_STORE_DATA_DIR, DEFAULT_UPDATES_LISTENER, NOTICES_FILTERED_PROPERTY, NOTIFIER_CLASS_PROPERTY, POLATOR_CLASS_PROPERTY, PULL_DISABLED_PROPERTY, REPLICATOR_CLASS_PROPERTY, RESPONSE_LIMIT_PROPERTY, STORE_DATA_DIR_PROPERTY, STORE_NAME_PROPERTY, UPDATES_LISTENER_CLASS_PROPERTY, UPDATES_LISTENER_PROPERTIES

Fields inherited from class ServiceAppImpl

SERVICE_APP_PROPERTIES

Constructor Summary

Constructors

Constructor and Description
SinkServiceAppImpl()

Method Summary

Modifier and Type	Method and Description
Optional<OriginEntity>	getProcessor() Gets the processor.
int	getResponseLimit() Gets the response limit.
SinkServer	getServer() Gets the store server instance.
protected boolean	setUp() Sets up this store service.
void	start() Starts the application.
void	stop() Stops the application.
protected StoreMetadataFilter	storeMetadataFilter(String storeName, Collection<String> partnerNames) Returns a store metadata filter.
void	tearDown() Tears down the application.

Methods inherited from class StoreServiceAppImpl

addNotice, addNoticeListener, areNoticesFiltered, doPendingActions, getArchiver, getBackEndLimit, getDefaultStoreName, getEntityName, getNoticesFilter, getPolator, getReplicator, getServerName, getServerProperties, getStoreDataDir, getStoreEntity, getStoreStats, isNullRemoves, isPullDisabled, makeNoticesFilter, onNewMetadata, onSignal, rebind, refreshMetadata, refreshNoticesFilter, registerServer, registerServer, removeNoticeListener, run, sendNotices, setUp, setUp, setUpArchiver, setUpNotifier, unregisterServer

Methods inherited from class MetadataServiceAppImpl

getMetadata, getService, loadMetadata, setUp

Methods inherited from class ServiceAppImpl

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

Methods inherited from class Object

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

Methods inherited from interface StoreServiceApp

getServerName, getStoreEntity

Methods inherited from interface MetadataServiceApp

getEntityName, onNewMetadata, setUp

Methods inherited from interface ServiceApp

createStats, onAlert, onEvent, onServicesNotReady, onServicesReady, onSignal, setUp

Field Detail

DEFAULT_SINK_MODULE

public static final ClassDef DEFAULT_SINK_MODULE

Default sink module.

PROCESSOR_PROPERTY

public static final String PROCESSOR_PROPERTY

Processor property.

See Also:

Constant Field Values

SERVER_PROPERTIES

public static final String SERVER_PROPERTIES

Server properties.

See Also:

Constant Field Values

SINK_MODULE_CLASS_PROPERTY

public static final String SINK_MODULE_CLASS_PROPERTY

Specifies a class implementing the sink module interface.

See Also:

Constant Field Values

Constructor Detail

SinkServiceAppImpl

public SinkServiceAppImpl()

Method Detail

getProcessor

public Optional<OriginEntity> getProcessor()

Gets the processor.

Specified by:

getProcessor in interface SinkServiceApp

Returns:

The optional processor.

getResponseLimit

public int getResponseLimit()

Gets the response limit.

Overrides:

getResponseLimit in class StoreServiceAppImpl

Returns:

The response limit.

getServer

public SinkServer getServer()

Gets the store server instance.

Specified by:

getServer in interface StoreServiceApp

Returns:

The store server instance.

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 StoreServiceAppImpl

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 StoreServiceAppImpl

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 StoreServiceAppImpl

setUp

protected boolean setUp()

Sets up this store service.

Overrides:

setUp in class StoreServiceAppImpl

Returns:

True on success.

storeMetadataFilter

protected StoreMetadataFilter storeMetadataFilter(String storeName,
                                                  Collection<String> partnerNames)

Returns a store metadata filter.

Overrides:

storeMetadataFilter in class StoreServiceAppImpl

Parameters:

storeName - The store's name.

partnerNames - The name of the store partners (optional).

Returns:

A store metadata filter (null on failure).