public abstract class AbstractKernel extends java.lang.Object implements Kernel
EVENTS_PENDING
Modifier | Constructor and Description |
---|---|
protected |
AbstractKernel() |
Modifier and Type | Method and Description |
---|---|
protected void |
addEnvelope(Envelope env) |
protected void |
addEvent(EndpointEvent e) |
boolean |
hasEnvelopes()
Returns true if there are waiting envelopes.
|
protected long |
nextEndpointId() |
EndpointEvent |
nextEvent()
Removes and returnsn one endpoint event from the event queue or
null if there are no endpoint events.
|
Envelope |
read()
Removes one envelope from the received messages queue or
blocks until one is available.
|
protected void |
reportError(java.lang.Exception e) |
protected void |
wakeupReader() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
broadcast, initialize, terminate
protected void reportError(java.lang.Exception e)
protected void wakeupReader()
protected long nextEndpointId()
public boolean hasEnvelopes()
hasEnvelopes
in interface Kernel
public Envelope read() throws java.lang.InterruptedException
public EndpointEvent nextEvent()
protected void addEvent(EndpointEvent e)
protected void addEnvelope(Envelope env)