public interface ExecutionQueue
ExecutionQueue
implementation is responsible for implementing the JACOB reactive rules and
maintaining the state of the reactive broth.Modifier and Type | Method and Description |
---|---|
void |
add(CommChannel channel) |
void |
add(CommGroup group) |
CommChannel |
consumeExport(java.lang.String exportId) |
java.lang.String |
createExport(CommChannel channel) |
int |
cycle() |
Continuation |
dequeueReaction() |
void |
dumpState(java.io.PrintStream err) |
void |
enqueueReaction(Continuation continuation)
Add a continuation to the broth.
|
void |
flush() |
boolean |
hasReactions()
Are there any reactions that can be executed in the broth?
|
boolean |
isComplete() |
void |
setClassLoader(java.lang.ClassLoader classLoader) |
void |
setReplacementMap(ReplacementMap replacementMap) |
boolean hasReactions()
true
if there are "enabled" reactionsvoid enqueueReaction(Continuation continuation)
continuation
- the Continuation
to add to the brothContinuation dequeueReaction()
void add(CommChannel channel)
void add(CommGroup group)
java.lang.String createExport(CommChannel channel)
CommChannel consumeExport(java.lang.String exportId)
int cycle()
void flush()
void setClassLoader(java.lang.ClassLoader classLoader)
void setReplacementMap(ReplacementMap replacementMap)
boolean isComplete()
void dumpState(java.io.PrintStream err)