|
Groovy Documentation | |||||||
FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectgroovyx.gpars.serial.WithSerialId
gpars.actor.impl.MessageStream
gpars.actor.impl.ReceivingMessageStream
@SuppressWarnings({"ThrowableInstanceNeverThrown"}) class ReceivingMessageStream extends MessageStream
Nested Class Summary | |
---|---|
class |
ReceivingMessageStream.ReplyCategory
Enhances objects with the ability to send replies and detect message originators. |
Field Summary | |
---|---|
protected WeakHashMap |
obj2Sender
|
Constructor Summary | |
ReceivingMessageStream()
|
Method Summary | |
---|---|
protected List
|
getSenders()
|
protected Object
|
receive()
Retrieves a message from the message queue, waiting, if necessary, for a message to arrive. |
protected Object
|
receive(long timeout, TimeUnit units)
Retrieves a message from the message queue, waiting, if necessary, for a message to arrive. |
protected Object
|
receive(BaseDuration duration)
Retrieves a message from the message queue, waiting, if necessary, for a message to arrive. |
protected Object
|
receiveImpl()
Retrieves a message from the message queue, waiting, if necessary, for a message to arrive. |
protected Object
|
receiveImpl(long timeout, TimeUnit units)
Retrieves a message from the message queue, waiting, if necessary, for a message to arrive. |
protected void
|
reply(Object message)
Sends a reply to all currently processed messages. |
protected void
|
replyIfExists(Object message)
Sends a reply to all currently processed messages, which have been sent by an actor. |
Methods inherited from class MessageStream | |
---|---|
call, getRemoteClass, leftShift, reInterrupt, send, send, send, sendAndContinue, sendAndWait, sendAndWait, sendAndWait |
Field Detail |
---|
protected final WeakHashMap obj2Sender
Constructor Detail |
---|
ReceivingMessageStream()
Method Detail |
---|
@SuppressWarnings({"ReturnOfCollectionOrArrayField"}) protected final List getSenders()
protected final Object receive()
protected final Object receive(long timeout, TimeUnit units)
protected final Object receive(BaseDuration duration)
protected Object receiveImpl()
protected Object receiveImpl(long timeout, TimeUnit units)
protected final void reply(Object message)
protected final void replyIfExists(Object message)
Groovy Documentation