public class DelayedEventSource extends AbstractEventSource implements EventSource
caughtUpToRealtime, EVENT_LAG, EVENT_QUERY_INCREMENT, EVENT_REFRESH_INTERVAL, everCaughtUpToRealtime, increment, lag, lastQueryTime, MIN_INCREMENT, nearRealTimeInterval, NO_DNS, refreshInterval, sleepUntilTime
name, NAME_ELEMENT, RETRIES_ELEMENT
Modifier | Constructor and Description |
---|---|
|
DelayedEventSource(org.w3c.dom.Element config) |
protected |
DelayedEventSource(edu.iris.Fissures.model.TimeInterval delay,
EventSource source) |
Modifier and Type | Method and Description |
---|---|
boolean |
checkEvent(edu.sc.seis.fissuresUtil.cache.CacheEvent e) |
java.lang.String |
getDescription() |
edu.sc.seis.fissuresUtil.time.MicroSecondTimeRange |
getEventTimeRange() |
edu.iris.Fissures.model.TimeInterval |
getWaitBeforeNext()
If the source needs to wait for more events to arrive, it should return
the amount of time it wants to wait with this method.
|
boolean |
hasNext() |
edu.sc.seis.fissuresUtil.cache.CacheEvent[] |
next() |
caughtUpWithRealtime, decreaseQueryTimeWidth, getIncrement, getLag, getQueryEdge, getQueryStart, getQueryTime, getRefreshInterval, getSleepUntilTime, increaseQueryTimeWidth, isEverCaughtUpToRealtime, resetQueryTimeForLag, setIncrement, setLag, setQueryEdge, updateQueryEdge
appendToName, getFissuresNamingService, getName, getRetries, getRetryStrategy, setRetryStrategy
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
appendToName, getName, getRetries
protected DelayedEventSource(edu.iris.Fissures.model.TimeInterval delay, EventSource source)
public DelayedEventSource(org.w3c.dom.Element config) throws ConfigurationException
ConfigurationException
public java.lang.String getDescription()
getDescription
in interface EventSource
public edu.sc.seis.fissuresUtil.time.MicroSecondTimeRange getEventTimeRange()
getEventTimeRange
in interface EventSource
public edu.iris.Fissures.model.TimeInterval getWaitBeforeNext()
EventSource
getWaitBeforeNext
in interface EventSource
getWaitBeforeNext
in class AbstractEventSource
public boolean hasNext()
hasNext
in interface EventSource
public edu.sc.seis.fissuresUtil.cache.CacheEvent[] next()
next
in interface EventSource
public boolean checkEvent(edu.sc.seis.fissuresUtil.cache.CacheEvent e)