public class SinkServiceAppImpl extends StoreServiceAppImpl implements SinkServiceApp
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.
|
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
SERVICE_APP_PROPERTIES
Constructor and Description |
---|
SinkServiceAppImpl() |
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.
|
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
getMetadata, getService, loadMetadata, setUp
createStats, fail, getConfig, getConfigProperties, getDataDir, getJoinTimeout, getProperties, getSourceUUID, getThisLogger, getTimer, onAlert, onEvent, onServiceNotAvailableException, onServicesNotReady, onServicesReady
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getServerName, getStoreEntity
getEntityName, onNewMetadata, setUp
createStats, onAlert, onEvent, onServicesNotReady, onServicesReady, onSignal, setUp
public static final ClassDef DEFAULT_SINK_MODULE
public static final String PROCESSOR_PROPERTY
public static final String SERVER_PROPERTIES
public static final String SINK_MODULE_CLASS_PROPERTY
public Optional<OriginEntity> getProcessor()
getProcessor
in interface SinkServiceApp
public int getResponseLimit()
getResponseLimit
in class StoreServiceAppImpl
public SinkServer getServer()
getServer
in interface StoreServiceApp
public void start()
Overidden as needed by the application.
Called by the framework.
Should return only when the application is started.
start
in interface ServiceApp
start
in class StoreServiceAppImpl
public void stop()
Overidden as needed by the application.
Called by the framework.
stop
in interface ServiceApp
stop
in class StoreServiceAppImpl
public void tearDown()
Overidden as needed by the application.
Called by the framework and by overriding classes at the end of the override.
tearDown
in interface ServiceApp
tearDown
in class StoreServiceAppImpl
protected boolean setUp()
setUp
in class StoreServiceAppImpl
protected StoreMetadataFilter storeMetadataFilter(String storeName, Collection<String> partnerNames)
storeMetadataFilter
in class StoreServiceAppImpl
storeName
- The store's name.partnerNames
- The name of the store partners (optional).Copyright © 2003-2019 Serge Brisson. All Rights Reserved.