|
||||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | |||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | |||||||||
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.InterruptedExceptionEndpointEvent nextEvent()
|
||||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | |||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | |||||||||