Package | Description |
---|---|
org.agilewiki.jactor.apc |
The apc package implements Asynchronous Procedure Calls (APC), or two-way messaging.
|
org.agilewiki.jactor.lpc |
Introducing JLPCActor--the Basic Actor
|
Modifier and Type | Class and Description |
---|---|
class |
JARequest
Requests sent to a JAPCMailbox are wrapped by an JARequest.
|
class |
JAResponse
Responses sent to a JAPCActor are wrapped by an JAResponse,
which is then passed to the JAPCMailbox.
|
Modifier and Type | Method and Description |
---|---|
EventQueue<ArrayList<JAMessage>> |
JAPCMailbox.getEventQueue()
Returns the event queue.
|
EventQueue<ArrayList<JAMessage>> |
APCMailbox.getEventQueue()
Returns the event queue.
|
Modifier and Type | Method and Description |
---|---|
void |
JAPCMailbox.putBufferedEvents(ArrayList<JAMessage> bufferedEvents)
The putBufferedEvents method adds events to be processed.
|
void |
JARequest.response(BufferedEventsQueue<JAMessage> eventQueue,
Object unwrappedResponse)
Enqueue a response to be sent when there are no more incoming messages to be processed.
|
void |
APCRequestSource.responseFrom(BufferedEventsQueue<JAMessage> eventQueue,
JAResponse japcResponse)
Enqueues the response in the responder's outbox.
|
void |
JAPCMailbox.send(BufferedEventsDestination<JAMessage> destination,
JARequest request)
Buffer the request for subsequent sending.
|
void |
APCRequestSource.send(BufferedEventsDestination<JAMessage> destination,
JARequest japcRequest)
Sends a request to a mailbox.
|
void |
APCMailbox.send(BufferedEventsDestination<JAMessage> destination,
JARequest request)
Buffer the request for subsequent sending.
|
Constructor and Description |
---|
JAPCMailbox(BufferedEventsQueue<JAMessage> bufferedEventQueue,
MailboxFactory mailboxFactory)
Create a JAPCMailbox.
|
Modifier and Type | Method and Description |
---|---|
void |
JLPCActor.responseFrom(BufferedEventsQueue<JAMessage> eventQueue,
JAResponse japcResponse)
Enqueues the response in the responder's outbox.
|
void |
JLPCActor.send(BufferedEventsDestination<JAMessage> destination,
JARequest japcRequest)
Sends a request to a mailbox.
|
Constructor and Description |
---|
JLPCMailbox(BufferedEventsQueue<JAMessage> eventQueue,
MailboxFactory mailboxFactory)
Create a JLPCMailbox.
|
Copyright © 2012. All Rights Reserved.