public class SinkBox<Msg extends Serializable> extends QueuedMailbox<Msg>
capacity, depositBlocks, open, queue
ref
Modifier | Constructor and Description |
---|---|
protected |
SinkBox(Class<Msg> msgClass) |
Modifier and Type | Method and Description |
---|---|
<T extends Serializable> |
checkType(Class<T> msgClass)
Returns THIS, assuming that THIS conveys messages of class MSGCLASS.
|
static <Msg extends Serializable> |
create()
A new SinkBox with no type checking.
|
static <Msg extends Serializable> |
create(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.
|
Class<Msg> |
messageType()
The (runtime) type of message sent through this box.
|
capacity, close, close, create, create, deposit, deposit, flush, forward, forwardTo, forwardTo, isClosed, isForwarding, myWait, receive, receive, stopForwarding
clone, exportObject, exportObject, exportObject, unexportObject
getClientHost, getLog, setLog
protected SinkBox(Class<Msg> msgClass) throws RemoteException
RemoteException
public static <Msg extends Serializable> SinkBox<Msg> create(Class<Msg> msgClass)
public static <Msg extends Serializable> SinkBox<Msg> create()
protected void enqueue(Msg msg)
QueuedMailbox
enqueue
in class QueuedMailbox<Msg extends Serializable>
public Class<Msg> messageType()
Mailbox
messageType
in interface Mailbox<Msg extends Serializable>
public <T extends Serializable> Mailbox<T> checkType(Class<T> msgClass)
Mailbox
checkType
in interface Mailbox<Msg extends Serializable>