public abstract class AbstractEventSource extends AbstractSource implements EventSource
Modifier and Type | Field and Description |
---|---|
protected boolean |
caughtUpToRealtime |
static java.lang.String |
EVENT_LAG |
static java.lang.String |
EVENT_QUERY_INCREMENT |
static java.lang.String |
EVENT_REFRESH_INTERVAL |
protected boolean |
everCaughtUpToRealtime |
protected TimeInterval |
increment |
protected TimeInterval |
lag |
protected MicroSecondDate |
lastQueryTime |
protected TimeInterval |
nearRealTimeInterval |
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 |
getIncrement() |
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 boolean |
isEverCaughtUpToRealtime() |
protected MicroSecondDate |
resetQueryTimeForLag()
Scoots the query time back by the event lag amount from the run
properties to the query start time at the earliest
|
void |
setIncrement(TimeInterval increment) |
void |
setLag(TimeInterval lag) |
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
protected boolean caughtUpToRealtime
protected boolean everCaughtUpToRealtime
protected MicroSecondDate lastQueryTime
public static final java.lang.String NO_DNS
protected MicroSecondDate sleepUntilTime
protected TimeInterval increment
protected TimeInterval lag
protected TimeInterval refreshInterval
protected TimeInterval nearRealTimeInterval
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 boolean isEverCaughtUpToRealtime()
protected MicroSecondDate getQueryStart()
protected MicroSecondTimeRange getQueryTime()
public void increaseQueryTimeWidth()
public void decreaseQueryTimeWidth()
protected MicroSecondDate 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 getIncrement()
public void setIncrement(TimeInterval increment)
public void setLag(TimeInterval lag)
public TimeInterval getRefreshInterval()