public abstract class AbstractEventSource extends AbstractSource implements EventSource
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
EVENT_LAG |
static java.lang.String |
EVENT_QUERY_INCREMENT |
static java.lang.String |
EVENT_REFRESH_INTERVAL |
protected TimeInterval |
increment |
protected TimeInterval |
lag |
static java.lang.String |
NO_DNS |
protected TimeInterval |
refreshInterval |
protected MicroSecondDate |
sleepUntilTime |
name, NAME_ELEMENT, RETRIES_ELEMENT
Constructor and Description |
---|
AbstractEventSource(org.w3c.dom.Element config,
java.lang.String defaultName) |
AbstractEventSource(java.lang.String name,
int retries) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
caughtUpWithRealtime() |
void |
decreaseQueryTimeWidth() |
TimeInterval |
getLag() |
protected MicroSecondDate |
getQueryEdge() |
protected MicroSecondDate |
getQueryStart() |
protected MicroSecondTimeRange |
getQueryTime() |
TimeInterval |
getRefreshInterval() |
MicroSecondDate |
getSleepUntilTime() |
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.
|
void |
increaseQueryTimeWidth() |
protected void |
resetQueryTimeForLag()
Scoots the query time back by the event lag amount from the run
properties to the query start time at the earliest
|
protected void |
setQueryEdge(MicroSecondDate edge)
sets the latest time queried
|
protected void |
updateQueryEdge(MicroSecondTimeRange queryTime) |
appendToName, getFissuresNamingService, getName, getRetries, getRetryStrategy, setRetryStrategy
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getDescription, getEventTimeRange, hasNext, next
appendToName, getName, getRetries
public static final java.lang.String NO_DNS
protected MicroSecondDate sleepUntilTime
protected TimeInterval increment
protected TimeInterval lag
protected TimeInterval refreshInterval
public static final java.lang.String EVENT_QUERY_INCREMENT
public static final java.lang.String EVENT_REFRESH_INTERVAL
public static final java.lang.String EVENT_LAG
public AbstractEventSource(java.lang.String name, int retries)
public AbstractEventSource(org.w3c.dom.Element config, java.lang.String defaultName) throws ConfigurationException
ConfigurationException
public TimeInterval getWaitBeforeNext()
EventSource
getWaitBeforeNext
in interface EventSource
protected boolean caughtUpWithRealtime()
protected MicroSecondDate getQueryStart()
protected MicroSecondTimeRange getQueryTime()
public void increaseQueryTimeWidth()
public void decreaseQueryTimeWidth()
protected void resetQueryTimeForLag()
protected MicroSecondDate getQueryEdge() throws NotFound
NotFound
protected void setQueryEdge(MicroSecondDate edge)
protected void updateQueryEdge(MicroSecondTimeRange queryTime)
public MicroSecondDate getSleepUntilTime()
public TimeInterval getLag()
public TimeInterval getRefreshInterval()