Package gov.usgs.earthquake.distribution
Class EIDSNotificationSender
- java.lang.Object
-
- gov.usgs.util.DefaultConfigurable
-
- gov.usgs.earthquake.product.AbstractListener
-
- gov.usgs.earthquake.distribution.DefaultNotificationListener
-
- gov.usgs.earthquake.distribution.DefaultNotificationSender
-
- gov.usgs.earthquake.distribution.EIDSNotificationSender
-
- All Implemented Interfaces:
NotificationIndexCleanup.Listener
,NotificationListener
,Configurable
public class EIDSNotificationSender extends DefaultNotificationSender
-
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
EIDS_DEFAULT_POLLDIR
Default directory where notifications are sent.static java.lang.String
EIDS_POLLDIR_PROPERTY
Property referencing directory where notifications are "sent".-
Fields inherited from class gov.usgs.earthquake.distribution.DefaultNotificationSender
DEFAULT_PRODUCT_STORAGE_MAX_AGE, PRODUCT_STORAGE_MAX_AGE_PROPERTY, PRODUCT_STORAGE_PROPERTY, productStorage, productStorageMaxAge, SERVER_HOST_PROPERTY, SERVER_PORT_PROPERTY, serverHost, serverPort
-
Fields inherited from class gov.usgs.earthquake.distribution.DefaultNotificationListener
CLEANUP_INTERVAL_PROPERTY, CONCURRENT_PRODUCTS_PROPERTY, DEFAULT_CLEANUP_INTERVAL, DEFAULT_CONCURRENT_PRODUCTS, DEFAULT_PROCESS_DUPLICATES, EXCLUDE_PATHS_PROPERTY, INCLUDE_PATHS_PROPERTY, INDEX_FILE_PROPERTY, NOTIFICATION_INDEX_PROPERTY, PROCESS_DUPLICATES
-
Fields inherited from class gov.usgs.earthquake.product.AbstractListener
ATTEMPT_COUNT_PROPERTY, DEFAULT_ATTEMPT_COUNT, DEFAULT_RETRY_DELAY, DEFAULT_TIMEOUT, EXCLUDE_SOURCES_PROPERTY, EXCLUDE_TYPES_PROPERTY, INCLUDE_ACTUALS_PROPERTY, INCLUDE_DEVELOPMENTS_PROPERTY, INCLUDE_INTERNALS_PROPERTY, INCLUDE_SCENARIOS_PROPERTY, INCLUDE_SOURCES_PROPERTY, INCLUDE_TESTS_PROPERTY, INCLUDE_TYPES_PROPERTY, MAX_TRIES_PROPERTY, RETRY_DELAY_PROPERTY, TIMEOUT_PROPERTY
-
-
Constructor Summary
Constructors Constructor Description EIDSNotificationSender()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
configure(Config config)
Configures based on configuration section.java.io.File
getServerPolldir()
protected void
sendNotification(Notification notification)
Utility method to do the actual notification sending.void
setServerPolldir(java.io.File serverPolldir)
void
shutdown()
Shut down storagevoid
startup()
Start up storage-
Methods inherited from class gov.usgs.earthquake.distribution.DefaultNotificationSender
getProductStorage, getProductStorageMaxAge, getServerHost, getServerPort, onAfterProcessNotification, onBeforeProcessNotification, onExpiredNotification, onProduct, setProductStorage, setProductStorageMaxAge, setServerHost, setServerPort
-
Methods inherited from class gov.usgs.earthquake.distribution.DefaultNotificationListener
cleanup, getCleanupInterval, getConcurrentProducts, getExcludePaths, getIncludePaths, getNotificationIndex, isProcessDuplicates, onBeforeProcessProduct, onNotification, setCleanupInterval, setConcurrentProducts, setNotificationIndex, setProcessDuplicates
-
Methods inherited from class gov.usgs.earthquake.product.AbstractListener
accept, getExcludeSources, getExcludeTypes, getIncludeSources, getIncludeTypes, getMaxTries, getRetryDelay, getTimeout, isIncludeActuals, isIncludeDevelopments, isIncludeInternals, isIncludeScenarios, isIncludeTests, setIncludeActuals, setIncludeDevelopments, setIncludeInternals, setIncludeScenarios, setIncludeTests, setMaxTries, setRetryDelay, setTimeout
-
Methods inherited from class gov.usgs.util.DefaultConfigurable
getName, setName
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface gov.usgs.util.Configurable
getName, setName
-
Methods inherited from interface gov.usgs.earthquake.distribution.NotificationListener
getMaxTries, getTimeout
-
-
-
-
Field Detail
-
EIDS_POLLDIR_PROPERTY
public static final java.lang.String EIDS_POLLDIR_PROPERTY
Property referencing directory where notifications are "sent".- See Also:
- Constant Field Values
-
EIDS_DEFAULT_POLLDIR
public static final java.lang.String EIDS_DEFAULT_POLLDIR
Default directory where notifications are sent.- See Also:
- Constant Field Values
-
-
Method Detail
-
sendNotification
protected void sendNotification(Notification notification) throws java.lang.Exception
Description copied from class:DefaultNotificationSender
Utility method to do the actual notification sending. Should be overridden by subclasses.- Overrides:
sendNotification
in classDefaultNotificationSender
- Parameters:
notification
- The notification to send- Throws:
java.lang.Exception
- if something goes wrong
-
configure
public void configure(Config config) throws java.lang.Exception
Description copied from class:DefaultNotificationSender
Configures based on configuration section.- Specified by:
configure
in interfaceConfigurable
- Overrides:
configure
in classDefaultNotificationSender
- Parameters:
config
- The config- Throws:
java.lang.Exception
- if something goes wrong
-
shutdown
public void shutdown() throws java.lang.Exception
Description copied from class:DefaultNotificationSender
Shut down storage- Specified by:
shutdown
in interfaceConfigurable
- Overrides:
shutdown
in classDefaultNotificationSender
- Throws:
java.lang.Exception
- if something goes wrong
-
startup
public void startup() throws java.lang.Exception
Description copied from class:DefaultNotificationSender
Start up storage- Specified by:
startup
in interfaceConfigurable
- Overrides:
startup
in classDefaultNotificationSender
- Throws:
java.lang.Exception
- if something goes wrong
-
getServerPolldir
public java.io.File getServerPolldir()
- Returns:
- serverPolldir
-
setServerPolldir
public void setServerPolldir(java.io.File serverPolldir)
- Parameters:
serverPolldir
- file to set
-
-