|
||||||||||
前のクラス 次のクラス | フレームあり フレームなし | |||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |
public interface Kernel
Defines the basic byte[] passing messaging kernel.
フィールドの概要 | |
---|---|
static Envelope |
EVENTS_PENDING
A marker envelope returned from read() that indicates that there are events pending. |
メソッドの概要 | |
---|---|
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. |
フィールドの詳細 |
---|
static final Envelope EVENTS_PENDING
メソッドの詳細 |
---|
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()
|
||||||||||
前のクラス 次のクラス | フレームあり フレームなし | |||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |