Package gov.usgs.earthquake.eids

Class EIDSProductReceiver

java.lang.Object

gov.usgs.util.DefaultConfigurable

gov.usgs.earthquake.distribution.DefaultNotificationReceiver

gov.usgs.earthquake.distribution.EIDSNotificationReceiver

gov.usgs.earthquake.eids.EIDSProductReceiver

All Implemented Interfaces:

NotificationIndexCleanup.Listener, NotificationReceiver, EIDSListener, Configurable

public class EIDSProductReceiver
extends EIDSNotificationReceiver

Wrap EIDSProductBuilder in NotificationReceiver interface.

Field Summary

Fields inherited from class gov.usgs.earthquake.distribution.EIDSNotificationReceiver

EIDS_ALTERNATE_SERVERS, EIDS_DEBUG, EIDS_MAX_EVENT_AGE, EIDS_SERVER_HOST_PROPERTY, EIDS_SERVER_PORT, EIDS_TRACKING_FILE

Fields inherited from class gov.usgs.earthquake.distribution.DefaultNotificationReceiver

CONNECT_TIMEOUT_PROPERTY, DEFAULT_CONNECT_TIMEOUT, DEFAULT_PRODUCT_STORAGE_MAX_AGE, DEFAULT_READ_TIMEOUT, DEFAULT_RECEIVER_CLEANUP, EXECUTOR_LISTENER_NOTIFIER, FUTURE_LISTENER_NOTIFIER, INDEX_FILE_PROPERTY, LISTENER_NOTIFIER_PROPERTY, NOTIFICATION_INDEX_PROPERTY, PRODUCT_STORAGE_MAX_AGE_PROPERTY, PRODUCT_STORAGE_PROPERTY, READ_TIMEOUT_PROPERTY, RECEIVER_CLEANUP_PROPERTY, ROUNDROBIN_LISTENER_NOTIFIER, STORAGE_DIRECTORY_PROPERTY

Constructor Summary

Constructors

Constructor	Description
EIDSProductReceiver()	Construct a new EIDSProductReceiver.

Method Summary

Modifier and Type	Method	Description
void	configure(Config config)	Process configuration settings.
void	onEIDSMessage(EIDSMessageEvent event)	Receive messages from the EIDSNotificationReceiver EIDS Client.s Forwards messages to builder, which sends built products to receiveNotification method.

Methods inherited from class gov.usgs.earthquake.distribution.EIDSNotificationReceiver

getClient, setClient, shutdown, startup

Methods inherited from class gov.usgs.earthquake.distribution.DefaultNotificationReceiver

addNotificationListener, getConnectTimeout, getListenerQueueStatus, getNotificationIndex, getNotifier, getProductStorage, getProductStorageMaxAge, getQueueStatus, getReadTimeout, getReceiverCleanupInterval, notifyListeners, onExpiredNotification, receiveNotification, removeExpiredNotifications, removeNotificationListener, retrieveProduct, sendNotifications, setConnectTimeout, setNotificationIndex, setNotifier, setProductStorage, setProductStorageMaxAge, setReadTimeout, setReceiverCleanupInterval, storeProductSource, throttleQueues

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

Constructor Detail

EIDSProductReceiver

public EIDSProductReceiver()

Construct a new EIDSProductReceiver. Uses the Configurable interface, see EIDSNotificationReceiver.

Method Detail

onEIDSMessage

public void onEIDSMessage(EIDSMessageEvent event)

Receive messages from the EIDSNotificationReceiver EIDS Client.s Forwards messages to builder, which sends built products to receiveNotification method.

Specified by:

onEIDSMessage in interface EIDSListener

Overrides:

onEIDSMessage in class EIDSNotificationReceiver

Parameters:

event - an event object representing the message that was received.

configure

public void configure(Config config)
               throws java.lang.Exception

Description copied from class: DefaultConfigurable

Process configuration settings. Called before startup().

Specified by:

configure in interface Configurable

Overrides:

configure in class EIDSNotificationReceiver

Parameters:

config - the Config object with settings.

Throws:

java.lang.Exception - if configuration exceptions occur.