...
Today the source is forced to sleep itself if it wants to poll less frequently. We want to be able to configure this:
...
allow the source to change this. For example, it may want to implement exponential backoff if the system it is polling is down. To accomplish this, we can add a couple methods to RealtimeContext to get and set the pollDelay:
| Code Block |
|---|
public interface RealtimeContext extends TransformContext {
...
// set poll delay in milliseconds
void setPollDelay(long duration);
// set poll delay in the given time unit
void setPollDelay(long duration, TimeUnit unit);
// get poll delay in milliseconds
long getPollDelay();
// get poll delay in the given time unit
long getPollDelay(TimeUnit unit);
}
@Override
public abstract SourceState poll(Emitter<T> writer, SourceState currentState) throws Exception {
try {
// perform request
context.setPollDelay(100);
} catch (Exception e) {
context.setPollDelay(context.getPollDelay() * 2);
return currentState;
}
} |
| Jira Legacy | ||||||
|---|---|---|---|---|---|---|
|
...