public interface IDispatcher extends IControllable, ICountable
After a queue has been created, it can be added to a dispatcher. The dispatcher will manage the process of enqueuing actions to the queues given to it in an orderly fashion.
Multiple dispatchers can be created to ensure that proper queue throughput can be achieved.
Modifier and Type | Method and Description |
---|---|
void |
add(IQueue queue)
Add a queue to this dispatcher.
|
void |
dispatch(IKAction action)
Dispatch an action to an appropriate queue.
|
void |
dispatch(IKAction action,
IQueue queue)
Dispatch an action to a particular queue.
|
IQueue |
getQueue() |
IQueue[] |
getQueues()
Get a list of the queues about which this dispatcher knows.
|
void |
remove(IQueue queue)
Remove a queue from a dispatcher.
|
void |
setQueue(IQueue queue) |
void |
step() |
drain, isPaused, isRunning, pause, resume, shutdown
addCounter, getCounter, getCounters, resetCounters
void dispatch(IKAction action)
action
- the kernel actionQueueException
- if there are no operational queues for this actionvoid dispatch(IKAction action, IQueue queue)
action
- the kernel actionqueue
- the queueQueueException
- if the queue is not operational or not foundvoid add(IQueue queue)
queue
- void remove(IQueue queue)
queue
- QueueException
- if the queue is not foundIQueue[] getQueues()
null
if none are foundIQueue getQueue()
void setQueue(IQueue queue)
void step()
© Copyright IBM Corp. 2013. All rights reserved.