Modifiers | Name | Description |
---|---|---|
private MessageStream |
sender |
A list of senders for the currently processed messages |
private static long |
serialVersionUID |
Fields inherited from class | Fields |
---|---|
class Actor |
ACTOR_HAS_ALREADY_BEEN_STARTED, AFTER_START, CANNOT_SEND_REPLIES_NO_SENDER_HAS_BEEN_REGISTERED, EMPTY_ARGUMENTS, ON_DELIVERY_ERROR, RESPONDS_TO, START_MESSAGE, STOP_MESSAGE, TERMINATE_MESSAGE, TIMEOUT, TIMEOUT_MESSAGE, currentActorPerThread, currentThread, joinLatch, onStop, parallelGroup, serialVersionUID, timer |
class MessageStream |
serialVersionUID |
class WithSerialId |
serialHandle, serialVersionUID |
Constructor and description |
---|
ReplyingMessageStream
() |
Type | Name and description |
---|---|
protected MessageStream |
getSender() |
protected void |
reply(java.lang.Object message) Sends a reply to all currently processed messages. |
protected void |
replyIfExists(java.lang.Object message) Sends a reply to all currently processed messages, which have been sent by an actor. |
protected void |
setSender(MessageStream sender) |
A list of senders for the currently processed messages
Sends a reply to all currently processed messages. Throws ActorReplyException if some messages have not been sent by an actor. For such cases use replyIfExists().
message
- reply messageSends a reply to all currently processed messages, which have been sent by an actor. Ignores potential errors when sending the replies, like no sender or sender already stopped.
message
- reply messageCopyright © 2008–2014 Václav Pech. All Rights Reserved.