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.StringEIDS_DEFAULT_POLLDIRDefault directory where notifications are sent.static java.lang.StringEIDS_POLLDIR_PROPERTYProperty 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 voidconfigure(Config config)Configures based on configuration section.java.io.FilegetServerPolldir()protected voidsendNotification(Notification notification)Utility method to do the actual notification sending.voidsetServerPolldir(java.io.File serverPolldir)voidshutdown()Shut down storagevoidstartup()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:DefaultNotificationSenderUtility method to do the actual notification sending. Should be overridden by subclasses.- Overrides:
sendNotificationin 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:DefaultNotificationSenderConfigures based on configuration section.- Specified by:
configurein interfaceConfigurable- Overrides:
configurein classDefaultNotificationSender- Parameters:
config- The config- Throws:
java.lang.Exception- if something goes wrong
-
shutdown
public void shutdown() throws java.lang.ExceptionDescription copied from class:DefaultNotificationSenderShut down storage- Specified by:
shutdownin interfaceConfigurable- Overrides:
shutdownin classDefaultNotificationSender- Throws:
java.lang.Exception- if something goes wrong
-
startup
public void startup() throws java.lang.ExceptionDescription copied from class:DefaultNotificationSenderStart up storage- Specified by:
startupin interfaceConfigurable- Overrides:
startupin 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
-
-