public interface Dispatcher
Dispatcher
implementation that you can use
to dispatch EMA dispatchable objects like OmmConsumer
s.
Dispatcher
s provide a number of helper methods that facilitates
EMA objects dispatching for common use cases.
Dispatcher
s must only be used with
OmmConsumer
s that have been properly initialized and configured
with the USER_DISPATCH operational model.Modifier and Type | Interface and Description |
---|---|
static class |
Dispatcher.Builder
Used to build
Dispatcher objects. |
Modifier and Type | Field and Description |
---|---|
static int |
FIFTEEN_SECONDS
Duration of 15 seconds that can be used as a parameter of
dispatchEventsUntilTimeElapsed(int) . |
static int |
FIVE_MINUTE
Duration of 5 minutes that can be used as a parameter of
dispatchEventsUntilTimeElapsed(int) . |
static int |
FIVE_SECONDS
Duration of 5 seconds that can be used as a parameter of
dispatchEventsUntilTimeElapsed(int) . |
static int |
ONE_MINUTE
Duration of 1 minute that can be used as a parameter of
dispatchEventsUntilTimeElapsed(int) . |
static int |
TEN_MINUTE
Duration of 10 minutes that can be used as a parameter of
dispatchEventsUntilTimeElapsed(int) . |
static int |
TEN_SECONDS
Duration of 10 seconds that can be used as a parameter of
dispatchEventsUntilTimeElapsed(int) . |
static int |
THIRTY_SECONDS
Duration of 30 seconds that can be used as a parameter of
dispatchEventsUntilTimeElapsed(int) . |
static int |
TWENTY_SECONDS
Duration of 20 seconds that can be used as a parameter of
dispatchEventsUntilTimeElapsed(int) . |
static int |
TWO_MINUTES
Duration of 2 minutes that can be used as a parameter of
dispatchEventsUntilTimeElapsed(int) . |
static int |
TWO_SECONDS
Duration of 2 seconds that can be used as a parameter of
dispatchEventsUntilTimeElapsed(int) . |
Modifier and Type | Method and Description |
---|---|
void |
dispatchEventsForever()
Dispatch events forever.
|
void |
dispatchEventsUntilComplete(Completable completable)
Dispatch events until the object given in parameter is complete.
|
void |
dispatchEventsUntilKeyPressed()
Dispatch events until the user presses <Enter> in the console.
|
void |
dispatchEventsUntilTimeElapsed(int durationInSeconds)
Dispatch events until the duration given in parameter is expired.
|
static final int TWO_SECONDS
dispatchEventsUntilTimeElapsed(int)
.static final int FIVE_SECONDS
dispatchEventsUntilTimeElapsed(int)
.static final int TEN_SECONDS
dispatchEventsUntilTimeElapsed(int)
.static final int FIFTEEN_SECONDS
dispatchEventsUntilTimeElapsed(int)
.static final int TWENTY_SECONDS
dispatchEventsUntilTimeElapsed(int)
.static final int THIRTY_SECONDS
dispatchEventsUntilTimeElapsed(int)
.static final int ONE_MINUTE
dispatchEventsUntilTimeElapsed(int)
.static final int TWO_MINUTES
dispatchEventsUntilTimeElapsed(int)
.static final int FIVE_MINUTE
dispatchEventsUntilTimeElapsed(int)
.static final int TEN_MINUTE
dispatchEventsUntilTimeElapsed(int)
.void dispatchEventsUntilComplete(Completable completable) throws com.thomsonreuters.ema.access.OmmException
completable
- the object that must be completed.com.thomsonreuters.ema.access.OmmException
void dispatchEventsUntilTimeElapsed(int durationInSeconds) throws com.thomsonreuters.ema.access.OmmException
durationInSeconds
- the duration in seconds.com.thomsonreuters.ema.access.OmmException
void dispatchEventsUntilKeyPressed() throws com.thomsonreuters.ema.access.OmmException
com.thomsonreuters.ema.access.OmmException
void dispatchEventsForever() throws com.thomsonreuters.ema.access.OmmException
com.thomsonreuters.ema.access.OmmException