java.io.Serializable
, java.rmi.Remote
, Mailbox<Msg>
public class SinkBox<Msg extends java.io.Serializable> extends QueuedMailbox<Msg>
capacity, depositBlocks, open, queue
Modifier | Constructor | Description |
---|---|---|
protected |
SinkBox(java.lang.Class<Msg> msgClass) |
Modifier and Type | Method | Description |
---|---|---|
<T extends java.io.Serializable> |
checkType(java.lang.Class<T> msgClass) |
Returns THIS, assuming that THIS conveys messages of class MSGCLASS.
|
static <Msg extends java.io.Serializable> |
create() |
A new SinkBox with no type checking.
|
static <Msg extends java.io.Serializable> |
create(java.lang.Class<Msg> msgClass) |
A new SinkBox for messages of type MSGCLASS.
|
protected void |
enqueue(Msg msg) |
Place MSG at the end of the message queue.
|
java.lang.Class<Msg> |
messageType() |
The (runtime) type of message sent through this box.
|
finalize, getClass, notify, notifyAll, wait, wait, wait
capacity, close, close, create, create, deposit, deposit, flush, forward, forwardTo, forwardTo, isClosed, isForwarding, myWait, receive, receive, stopForwarding
protected SinkBox(java.lang.Class<Msg> msgClass) throws java.rmi.RemoteException
java.rmi.RemoteException
public static <Msg extends java.io.Serializable> SinkBox<Msg> create(java.lang.Class<Msg> msgClass)
public static <Msg extends java.io.Serializable> SinkBox<Msg> create()
protected void enqueue(Msg msg)
QueuedMailbox
enqueue
in class QueuedMailbox<Msg extends java.io.Serializable>
public java.lang.Class<Msg> messageType()
Mailbox
messageType
in interface Mailbox<Msg extends java.io.Serializable>