Package gov.usgs.earthquake.eidsutil
Class EIDSClient
java.lang.Object
gov.usgs.earthquake.eidsutil.EIDSClient
- All Implemented Interfaces:
EIDSListener
An EIDS client that is a java event source.
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final Long
Default client restart intervalstatic final Double
Default maxServerEventAgeDays parameter.static final String
Default server host.static final Integer
Default server port number.static final String
Default Tracking filename.static final String
Property name for eids server alternate servers list.static final String
Property name for objects to load and add as EIDSListeners.static final String
Property name for eids server host address.static final String
Property name for eids server port.static final String
Name string for program.static final String
Version string for program. -
Constructor Summary
ConstructorsConstructorDescriptionConstructor using default host and portEIDSClient
(String serverHost, Integer serverPort) Construct an EIDSClient using only server host and port.EIDSClient
(String serverHost, Integer serverPort, String alternateServersList) Construct an EIDSClient using serverHost, serverPort, and alternateServersList.EIDSClient
(String serverHost, Integer serverPort, String alternateServersList, Double maxServerEventAgeDays, String trackingFileName, Long clientRestartInterval) Constructor with all options. -
Method Summary
Modifier and TypeMethodDescriptionvoid
addListener
(EIDSListener listener) Add a listener.boolean
isDebug()
static void
A method to test the EIDSClient.void
onEIDSMessage
(EIDSMessageEvent event) Receive a message from an EIDSClient.boolean
void
removeListener
(EIDSListener listener) Remove a listener.void
setAlternateServersList
(String alternateServersList) void
setClientRestartInterval
(Long clientRestartInterval) void
setDebug
(boolean debug) void
setMaxServerEventAgeDays
(Double maxServerEventAgeDays) void
setServerHost
(String serverHost) void
setServerPort
(Integer serverPort) void
setTrackingFileName
(String trackingFileName) void
shutdown()
Shuts down a running client.void
startup()
Runs the client.
-
Field Details
-
EIDS_SERVER_HOST_PROPERTY
Property name for eids server host address.- See Also:
-
EIDS_SERVER_PORT
Property name for eids server port.- See Also:
-
EIDS_ALTERNATE_SERVERS
Property name for eids server alternate servers list.- See Also:
-
EIDS_LISTENERS
Property name for objects to load and add as EIDSListeners.- See Also:
-
PROGRAM_VERSION
Version string for program.- See Also:
-
PROGRAM_NAME
Name string for program.- See Also:
-
DEFAULT_SERVER_HOST
Default server host.- See Also:
-
DEFAULT_SERVER_PORT
Default server port number. -
DEFAULT_MAX_SERVER_EVENT_AGE_DAYS
Default maxServerEventAgeDays parameter. -
DEFAULT_TRACKING_FILE_NAME
Default Tracking filename.- See Also:
-
DEFAULT_CLIENT_RESTART_INTERVAL
Default client restart interval
-
-
Constructor Details
-
EIDSClient
public EIDSClient()Constructor using default host and port -
EIDSClient
Construct an EIDSClient using only server host and port. Calls other constructor with null values for other parameters.- Parameters:
serverHost
- Specific hostserverPort
- Specific port
-
EIDSClient
Construct an EIDSClient using serverHost, serverPort, and alternateServersList.- Parameters:
serverHost
- HostserverPort
- PortalternateServersList
- a comma delimited list of host:port that are used when unable to connect to the primary serverHost and serverPort.
-
EIDSClient
public EIDSClient(String serverHost, Integer serverPort, String alternateServersList, Double maxServerEventAgeDays, String trackingFileName, Long clientRestartInterval) Constructor with all options.- Parameters:
serverHost
- the eids server host or ip address.serverPort
- the eids server port.alternateServersList
- a comma delimited list of host:port that are used when unable to connect to the primary serverHost and serverPort.maxServerEventAgeDays
- number of days worth of messages to retrieve on first connect.trackingFileName
- location where tracking file is stored. This file is used to track which messages have been received.clientRestartInterval
- How often to periodically restart the client, in milliseconds
-
-
Method Details
-
startup
public void startup()Runs the client. Any listeners should be added before calling this method. -
shutdown
public void shutdown()Shuts down a running client. Does not call system.exit. -
addListener
Add a listener.- Parameters:
listener
- the listener to add.
-
removeListener
Remove a listener.- Parameters:
listener
- the listener to remove.
-
onEIDSMessage
Description copied from interface:EIDSListener
Receive a message from an EIDSClient.- Specified by:
onEIDSMessage
in interfaceEIDSListener
- Parameters:
event
- an event object representing the message that was received.
-
getServerHost
- Returns:
- the serverHost
-
setServerHost
- Parameters:
serverHost
- the serverHost to set
-
getServerPort
- Returns:
- the serverPort
-
setServerPort
- Parameters:
serverPort
- the serverPort to set
-
getAlternateServersList
- Returns:
- the alternateServersList
-
setAlternateServersList
- Parameters:
alternateServersList
- the alternateServersList to set
-
getMaxServerEventAgeDays
- Returns:
- the maxServerEventAgeDays
-
setMaxServerEventAgeDays
- Parameters:
maxServerEventAgeDays
- the maxServerEventAgeDays to set
-
getTrackingFileName
- Returns:
- the trackingFileName
-
setTrackingFileName
- Parameters:
trackingFileName
- the trackingFileName to set
-
getClientRestartInterval
- Returns:
- clientRestartInterval
-
setClientRestartInterval
- Parameters:
clientRestartInterval
- the clientRestartInterval to set
-
setDebug
public void setDebug(boolean debug) - Parameters:
debug
- to set
-
isDebug
public boolean isDebug()- Returns:
- debug boolean
-
reinitConnection
public boolean reinitConnection()- Returns:
- result of reinitialzing the client connection
-
main
A method to test the EIDSClient.- Parameters:
args
- arguments- Throws:
Exception
- if error occurs
-