Package gov.usgs.earthquake.distribution
package gov.usgs.earthquake.distribution
Distribution distributes Products.
EmbeddedPDLClient- Provides an example configuration for PDL to be embedded in another java application.
ProductClient- The primary command-line entry point, via the
Bootstrapmain-class.
ProductSender- Used to send products to NotificationReceivers.
Usually directly usingSocketProductSender, or when running a central hub usingEIDSNotificationSender. NotificationReceiver- Used to receive products.
Usually by connecting to a hub usingEIDSNotificationReceiver, or when running a central hub usingSocketProductReceiver.
A receiver notifies all its listeners when new products are received. NotificationListener- Used to process received products.
Listeners receiveNotifications when new products are available, and can request a product be processed based on itssourceand/ortype.
TheDefaultNotificationListenerprocesses in a different thread, theExternalNotificationListenerexecutes an external process, andRelayProductListenerforwards products over a socket.
ProductStorage- Store product contents in the file system.
FileProductStoragesupports a number of different storage formats, including "directory", "xml", "binary", and "zip". NotificationIndex- Used to keep track of which products are in storage, have been processed, and when those products should be automatically cleaned up (if ever).
-
ClassDescriptionTelnet to this socket to get a "command prompt".Bootstrap is a class used to start an application.An interface used by the Bootstrap class to invoke the main class.Command Line Interface Product Builder.Class encapsulates commands including command line argumentsStatic exception class for when a command times outA configuration exception, thrown while loading the config file if there are problems.A listener that listens for a specific content path.An exception thrown when storing a product already in storage.Wrapper exception class.Send products by printing them in xml format on the command line.A DefaultNotification is a implementation of the Notification interface.A base implementation of a notification listener.The core of product distribution.The base class for all Notification senders.Interface class to implement custom actions around product storageDeflate an input stream.Receive XML notifications using EIDS.Class that works with EIDS interface and format for sending This class generally works by polling a specified directory and then when a files shows up in that directory it sends itAn example of an embedded PDL client.Executes notifcations on separate threadsAn external process that is called when new products arrive.Factory class for EIDS CLIENT to send and receive notifications and productsStore products in the file system.FutureListenerNotifier is similar to ExecutorListenerNotifier, but uses Futures with an ExecutorService to implement timeouts instead of Timers.Deprecated.HeartbeatInfo stores a single heartbeat key/value message, together with a timestampHeartbeat Listener stores heartbeat messages and writes them to a heartbeat file when a product is receivedHeartbeat status information for a single componentRead messages from files or a poll directory, and push products into PDL.An exception thrown when storing a product already in storage.Stores and retrieves Notifications.Interface for Notification ListenerA Notification describes an updated product that is available.An event sent to a NotificationListener.Stores and retrieves Notifications.NotificationIndexCleanup manages cleaning up expired notifications.Interface for cleanup listeners to take additional steps before a notification is removed.Process Notifications of Products.A Callable object for deferred listener notification.An exception thrown by a NotificationListener when it cannot process a product.Receives and processes notifications.An exception thrown when storing a product already in storage.Essentials for building/sending products.The entry point to product distribution.Used to define JMX monitoring interface.Interface used by the InputWedge to create products from files.This represents a public key used to verify product signatures.A group of keys that can be used to verify product signatures.A utility class to (re)send an existing product to pdl hubs.Send a product to a recipient.Stores and retrieves Products.Create Products from ANSS Quakeml files.Listen for products and uses any number of given product senders to send products as they are received.Class to handle replication of storageVerifies certificate/key signaturesReceive Products directly via a Socket.Handles incoming socket including lock/unlock on storageSend Products to SocketProductReceivers.Specialized event object for acting on PDL product storageEnumeration of
StorageEventTypesStorageListener interface is called when product storage is changed by a productA URLNotification represents a product that is available via a URL.Converts to and from JSON for URL notificationsThis class is not intended to be instantiated directly.Converts to and from XML for URL notificationsStore products in a file system which is also available at a URL.Different types of formatsManages a simple connection to a websocket.Allows overridden onMessage for different behavior of WebSocketClient onMessageReceives notifications from an arbitrary web socket.