|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface Kernel
Defines the basic byte[] passing messaging kernel.
Field Summary | |
---|---|
static Envelope |
EVENTS_PENDING
A marker envelope returned from read() that indicates that there are events pending. |
Method Summary | |
---|---|
void |
broadcast(Filter<? super Endpoint> filter,
java.nio.ByteBuffer data,
boolean reliable,
boolean copy)
Dispatches the data to all endpoints managed by the kernel that match the specified endpoint filter.. |
boolean |
hasEnvelopes()
Returns true if there are waiting envelopes. |
void |
initialize()
Initializes the kernel and starts any internal processing. |
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. |
void |
terminate()
Gracefully terminates the kernel and stops any internal daemon processing. |
Field Detail |
---|
static final Envelope EVENTS_PENDING
Method Detail |
---|
void initialize()
void terminate() throws java.lang.InterruptedException
java.lang.InterruptedException
void broadcast(Filter<? super Endpoint> filter, java.nio.ByteBuffer data, boolean reliable, boolean copy)
boolean hasEnvelopes()
Envelope read() throws java.lang.InterruptedException
java.lang.InterruptedException
EndpointEvent nextEvent()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |