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 returns 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, waitbroadcast, initialize, terminateprotected void reportError(java.lang.Exception e)
protected void wakeupReader()
protected long nextEndpointId()
public boolean hasEnvelopes()
hasEnvelopes in interface Kernelpublic Envelope read() throws java.lang.InterruptedException
public EndpointEvent nextEvent()
protected void addEvent(EndpointEvent e)
protected void addEnvelope(Envelope env)