Package | Description |
---|---|
casa |
The casa package is the main package for CASA (Collaborative Agent System
Architecture), which is an infrastructure for agent based systems.
|
casa.auction.dutch | |
casa.auction.sealedbid | |
casa.conversation2 | |
casa.event |
Contains classes that implement Events (see
Event ),
which are used to describe dependencies (including time expiry or time
intervals) among things like social commitments and deferred code. |
casa.interfaces |
Contains classes for important
interfaces used in CASA. |
casa.policy | |
casa.service |
Contains classes implementing classes for service agents.
|
casa.socialcommitments |
Contains classes implementing social commitments.
|
casa.socialcommitments.operators |
Modifier and Type | Field and Description |
---|---|
private ArrayList<Event> |
TransientAgent.subscribeEvents |
Modifier and Type | Method and Description |
---|---|
protected Event |
AbstractProcess.eventQueuePeek() |
static Event |
TransientAgent.getEventForThread()
Used by Lisp operators defined as subclasses of
CasaLispOperator to
access thread-local data. |
protected Event |
EventQueue.getItem() |
Event[] |
TransientAgent.getSubscribeEvents(Event event) |
Event |
TransientAgent.getSubscribeEvents(String conversationID) |
Modifier and Type | Method and Description |
---|---|
void |
TransientAgent.addSubscribeEvents(Event event) |
void |
AbstractProcess.dequeueEvent(Event event)
Remove the event from the agent's event queue
iff the event is already in the queue
|
Event[] |
TransientAgent.getSubscribeEvents(Event event) |
void |
YellowPagesAgent.handleEvent(Event event)
Handles the dispatching of all incoming messages to corresponding
functions, usually based upon the value of the "act" and "performative"
parameters of the message.
|
void |
TransientAgent.handleEvent(Event event)
Overrides
AbstractProcess.handleEvent(Event) by:
if this is a message event and the CONVERSATION-ID matches one of the
current conversations listed in TransientAgent.conversations , pass the event to
that conversation and collect the policies. |
void |
CooperationDomainObserver.handleEvent(Event event) |
void |
AgentRemoteProxy.handleEvent(Event event)
Overrides AbstractProcess.handleMessage() by first calling (and returning
the status of ) super.handleMessage(), which takes care of all replies.
|
void |
AgentProxy.handleEvent(Event event)
Handles the processing and dispatching of all incoming messages.
|
protected abstract void |
AbstractProcess.handleEvent(Event event)
This method is called from
AbstractProcess.processEvent(Event) . |
protected int |
EventQueue.insertPos(Event item)
Override of the template method change the behaviour of
method putItem().
|
protected void |
EventQueue.notifyNewItem(Event e) |
private void |
AbstractProcess.processEvent(Event event)
This method is a pre-processing step before the event from the event queue is passed
passed on to
AbstractProcess.handleEvent(Event) for actual processing event. |
private void |
TransientAgent.processPolicies(AbstractProcess creator,
Event event,
AbstractCollection<Pair<Conversation,AbstractPolicy>> collectedPolicies,
Conversation conversation,
String conversationsDoc,
Map<String,LispObject> map)
Applies the policies using
PolicyContainer.applyPolicies(casa.interfaces.PolicyAgentInterface, AbstractCollection, Event, Map) . |
void |
EventQueue.putItem(Event event)
Inserts an Event at the end of the buffer and checks to see if there
is a thread waiting on the message (in which case, it notifies the thread).
|
void |
AbstractProcess.queueEvent(Event event)
Queues an event to the agent's event queue
|
void |
AbstractProcess.queueEventIf(Event event)
Put the Event on the agent's event queue
iff the event is not already on the queue.
|
void |
TransientAgent.removeSubscribeEvents(Event event) |
Modifier and Type | Class and Description |
---|---|
private class |
DutchAuctionAgent.RecurringCryEvent |
Modifier and Type | Method and Description |
---|---|
void |
SealedBidAuctionAgent.handleEvent(Event event) |
Modifier and Type | Field and Description |
---|---|
(package private) Runnable1<Event,Status> |
Runnable1Action.runnable |
Modifier and Type | Method and Description |
---|---|
Runnable1<Event,Status> |
Runnable1Action.getAction() |
Modifier and Type | Method and Description |
---|---|
protected StatusObject<List<Object>> |
Conversation.applyPolicies(Event event)
***Warning: It's not very efficient to call this method.
|
Status |
Runnable1Action.execute(Event event) |
Status |
LispAction.execute(Event event) |
Status |
Action.execute(Event event) |
Vector<Pair<Conversation,AbstractPolicy>> |
Conversation.getApplicablePolicies(PolicyAgentInterface agent,
Event event)
Note that there is not "isApplicable(Event)" method in this class.
|
void |
ConversationInterface.waitForEvent(Event event,
long timeout) |
Modifier and Type | Method and Description |
---|---|
void |
Runnable1Action.setAction(Runnable1<Event,Status> action) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractEvent
AbstractEvent is an abstract class which implements
Event#addEventObserver(EventObserver) ,
Event#removeEventObserver(EventObserver) ,
getEventType() . |
class |
EventObserverEvent
Defines an Event that will be triggered when the owner agent receives a message
matching the patternPairs given in this constructor.
|
class |
MessageEvent |
class |
MessageObserverEvent
Defines an Event that will be triggered when the owner agent receives a message
matching the patternPairs given in this constructor.
|
class |
NonRecurringEvent
The NonRecurringEvent abstract class represents an event that does not recur.
|
class |
RecurringEvent
The RecurringEvent abstract class represents an event that does recur.
|
class |
RecurringTimeEvent
RecurringTimeEvent is a recurring event that occurs first at a specified time and then repeats indefinitely
with a fixed delay between occurrences.
|
class |
TimeEvent
TimeEvent is a non-recurring event that occurs at a specified time.
|
class |
TriggerEvent |
Modifier and Type | Method and Description |
---|---|
Status |
EventDescriptor.isApplicable(PolicyAgentInterface agent,
Event event)
Returns true if event descriptor matches the event in the context of
the agent.
|
void |
EventObserver.notifyEventOccurred(String type,
Event event,
Object instanceInfo)
Indicates that an event of the given type has occurred.
|
Modifier and Type | Method and Description |
---|---|
Event[] |
PolicyAgentInterface.getSubscribeEvents(Event event) |
Modifier and Type | Method and Description |
---|---|
void |
PolicyAgentInterface.dequeueEvent(Event event)
Remove the event from the agent's event queue
|
Event[] |
PolicyAgentInterface.getSubscribeEvents(Event event) |
void |
PolicyAgentInterface.queueEvent(Event event)
Put the Event on the agent's event queue.
|
void |
PolicyAgentInterface.queueEventIf(Event event)
Put the Event on the agent's event queue
iff the event is not already on the queue.
|
Modifier and Type | Field and Description |
---|---|
(package private) Event |
Policy.SCOpData.event |
(package private) Event[] |
Policy.SCOpData.events |
Modifier and Type | Method and Description |
---|---|
StatusObject<List<Object>> |
Policy.apply(PolicyAgentInterface agent,
Status status,
Vector<AbstractPolicy> policyContext,
Event event,
Map<String,LispObject> map,
Object eventInstanceInfo) |
StatusObject<List<Object>> |
AbstractPolicy.apply(PolicyAgentInterface agent,
Status status,
Vector<AbstractPolicy> policyContext,
Event event,
Map<String,LispObject> map,
Object eventInstanceInfo) |
StatusObject<List<Object>> |
PolicyContainer.applyPolicies(PolicyAgentInterface agent,
AbstractCollection<Pair<Conversation,AbstractPolicy>> applicablePolicies,
Event event,
Map<String,LispObject> map)
Apply all the appropriate policies to event after filtering and sorting.
|
protected StatusObject<List<Object>> |
Policy.executeConcequent(PolicyAgentInterface agent,
Status status,
Vector<AbstractPolicy> policyContext,
Event event,
Object eventInstanceInfo,
Map<String,LispObject> map) |
Vector<AbstractPolicy> |
PolicyContainer.findApplicable(PolicyAgentInterface agent,
Event event,
Map<String,LispObject> map) |
Status |
Policy.isApplicable(PolicyAgentInterface agent,
Event event,
Map<String,LispObject> map)
Determines if this policy is applicable to the event.
|
Status |
AbstractPolicy.isApplicable(PolicyAgentInterface agent,
Event event,
Map<String,LispObject> map) |
Modifier and Type | Method and Description |
---|---|
void |
ServiceAgent.handleEvent(Event event) |
Modifier and Type | Field and Description |
---|---|
private Event |
SocialCommitment.event
The event that caused the creation of this social commitment.
|
Modifier and Type | Field and Description |
---|---|
private Map<String,Event> |
SocialCommitment.events
A map which contains the events associated with this commitment.
|
Modifier and Type | Method and Description |
---|---|
private static Event[] |
DependantSocialCommitment.enbiggen(Event e,
Event... events) |
Event |
SocialCommitment.getEvent()
Retrieves the Event that caused the creation of this social commitment.
|
protected Event |
SocialCommitment.getEventOfType(String type)
Retrieves the event of the indicated type, if any.
|
Modifier and Type | Method and Description |
---|---|
void |
SocialCommitmentsStore.addCommitment(PolicyAgentInterface agent,
URLDescriptor debtor,
URLDescriptor creditor,
String performative,
Act act,
Event event,
Action action)
This adds a commitment with the specified arguments.
|
private static Event[] |
DependantSocialCommitment.enbiggen(Event e,
Event... events) |
private static Event[] |
DependantSocialCommitment.enbiggen(Event e,
Event... events) |
void |
SocialCommitmentsStore.removeCommitment(PolicyAgentInterface agent,
URLDescriptor debtor,
URLDescriptor creditor,
String performative,
Act act,
Event event,
Action action)
This removes a commitment formed from the parameters.
|
Constructor and Description |
---|
DependantSocialCommitment(PolicyAgentInterface agent,
SocialCommitment guard,
URLDescriptor newDebtor,
URLDescriptor newCreditor,
String newPerformative,
Act newAct,
Event event,
Action action) |
DependantSocialCommitment(PolicyAgentInterface agent,
SocialCommitment guard,
URLDescriptor newDebtor,
URLDescriptor newCreditor,
String newPerformative,
Act newAct,
Event event,
Action action,
Event... events) |
DependantSocialCommitment(PolicyAgentInterface agent,
SocialCommitment guard,
URLDescriptor newDebtor,
URLDescriptor newCreditor,
String newPerformative,
Act newAct,
Event event,
Action action,
Event... events) |
SocialCommitment(PolicyAgentInterface agent,
URLDescriptor newDebtor,
URLDescriptor newCreditor,
String newPerformative,
Act newAct,
Event event,
Action newAction)
Constructs a new social commitment from the given information.
|
SocialCommitment(PolicyAgentInterface agent,
URLDescriptor newDebtor,
URLDescriptor newCreditor,
String newPerformative,
Act newAct,
Event event,
Action newAction,
Event... newEvents)
Constructs a new social commitment from the given information.
|
SocialCommitment(PolicyAgentInterface agent,
URLDescriptor newDebtor,
URLDescriptor newCreditor,
String newPerformative,
Act newAct,
Event event,
Action newAction,
Event... newEvents)
Constructs a new social commitment from the given information.
|
Modifier and Type | Field and Description |
---|---|
private Event |
FulfilSocialCommitment.event |
private Event |
CancelSocialCommitment.event |
protected Event |
AddSocialCommitment.event |
protected Event[] |
AddSocialCommitment.events |
Modifier and Type | Method and Description |
---|---|
Event |
AddSocialCommitment.getEvent() |
Constructor and Description |
---|
AddDependentSocialCommitment(SocialCommitmentDescriptor scDescriptor,
URLDescriptor debtor,
URLDescriptor creditor,
String performative,
Act act,
Event event,
Class<? extends Action> actionClass,
Object actionData,
boolean shared,
boolean persistent,
Condition condition,
Event[] events) |
AddDependentSocialCommitment(SocialCommitmentDescriptor scDescriptor,
URLDescriptor debtor,
URLDescriptor creditor,
String performative,
Act act,
Event event,
Class<? extends Action> actionClass,
Object actionData,
boolean shared,
boolean persistent,
Condition condition,
Event[] events) |
AddSocialCommitment(URLDescriptor newDebtor,
URLDescriptor newCreditor,
String newPerformative,
Act newAct,
Event newEvent,
Class<? extends Action> newActionClass,
Object newActionData,
boolean newShared,
boolean newPersistent,
Condition newCondition,
Event[] newEvents) |
AddSocialCommitment(URLDescriptor newDebtor,
URLDescriptor newCreditor,
String newPerformative,
Act newAct,
Event newEvent,
Class<? extends Action> newActionClass,
Object newActionData,
boolean newShared,
boolean newPersistent,
Condition newCondition,
Event[] newEvents) |
CancelSocialCommitment(URLDescriptor debtor,
URLDescriptor creditor,
String performative,
Act act,
Event event) |
FulfilSocialCommitment(URLDescriptor debtor,
URLDescriptor creditor,
String performative,
Act act,
Event event) |