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.agentCom |
The package (agentCom = "Agent
Communications") handles connections between agents. The class Channel
is an abstraction of a communication channel.
|
casa.auction | |
casa.auction.dutch | |
casa.auction.english | |
casa.auction.sealedbid | |
casa.auction.vickrey | |
casa.conversation2 | |
casa.demo | |
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.jade | |
casa.policy.sc3 | |
casa.security | |
casa.service |
Contains classes implementing classes for service agents.
|
casa.socialcommitments |
Contains classes implementing social commitments.
|
casa.socialcommitments.operators | |
casa.testAgents | |
casa.transaction | |
casa.ui |
Contains classes implementing CASA's default user interfaces.
|
iRobotCreate |
Modifier and Type | Class and Description |
---|---|
class |
KQMLMessage
Copyright: Copyright 2003-2014, Knowledge Science Group, University of Calgary.
|
class |
XMLMessage
Title: CASA
Description: Based on the KQMLmessage class.
|
Modifier and Type | Field and Description |
---|---|
private List<MLMessage> |
StatusMLMessageList.messages |
private TreeSet<MLMessage> |
TransientAgent.outstandingRequests
Used to record all outgoing
requests to match against
incomming reply-requests (and then remove them). |
Modifier and Type | Method and Description |
---|---|
MLMessage |
MLMessage.clone() |
static MLMessage |
MLMessage.constructBasicProxyMessage(MLMessage message,
URLDescriptor sender,
URLDescriptor proxyReciever,
URLDescriptor finalReciever) |
static MLMessage |
CooperationDomain.constructCDProxyMessage(MLMessage message,
URLDescriptor sender,
URLDescriptor cd)
Constructs a new proxy message which instructs the cooperation domain to
forward the encapsulated message to all current members of that cooperation
domain.
|
static MLMessage |
CooperationDomain.constructCDProxyMessage(MLMessage message,
URLDescriptor sender,
URLDescriptor cd,
List<URLDescriptor> to,
boolean whisper)
Constructs a new proxy message which instructs the cooperation domain to
forward the encapsulated directed or whisper message.
|
static MLMessage |
CooperationDomain.constructCDProxyMessage(MLMessage message,
URLDescriptor sender,
URLDescriptor cd,
URLDescriptor to,
boolean whisper)
Constructs a new proxy message which instructs the cooperation domain to
forward the encapsulated directed or whisper message.
|
static MLMessage |
MLMessage.constructProxyMessage(MLMessage message,
URLDescriptor sender,
URLDescriptor proxyReciever,
String finalRecieverDescription) |
static MLMessage |
MLMessage.constructReplyTo(MLMessage m,
String replyWith,
URLDescriptor originator)
|
static MLMessage |
MLMessage.fromString(String text) |
MLMessage |
EventQueue.getMessageInReplyTo(MLMessage msg) |
static MLMessage |
TransientAgent.getMsgForThread()
Deprecated.
|
MLMessage |
AbstractProcess.getNewMessage(String performative,
String act,
URLDescriptor reciever)
Creates a basic message with the given performative, act, and reciever.
|
MLMessage |
AbstractProcess.getNewMessage(String performative,
String act,
URLDescriptor reciever,
String... list)
Creates a basic message with the given performative, act, and reciever.
|
static MLMessage |
MLMessage.getNewMLMessage()
Method for creating a new MLMessage of the default type (see setMarkupLanguage()).
|
static MLMessage |
MLMessage.getNewMLMessage(String... list)
Method for creating a new MLMessage depending on the messageType.
|
static MLMessage |
MLMessage.getNewMLMessageType(String markupLanguage)
Method for creating a new MLMessage depending on the messageType.
|
static MLMessage |
MLMessage.getNewMLMessageType(String markupLanguage,
String... list)
Method for creating a new MLMessage depending on the messageType.
|
private MLMessage |
TransientAgent.matchRequest(MLMessage replyRequestMsg)
Finds a request matching (in the
ML.IN_REPLY_TO and
ML.REPLY_WITH fields) and returns the matching message. |
private MLMessage |
TransientAgent.matchRequestAndDelete(MLMessage replyRequestMsg)
Finds a request matching (in the
ML.IN_REPLY_TO and
ML.REPLY_WITH fields), deletes the request from the internal list
of requests and returns the matching message. |
MLMessage |
MLMessage.reverseDirection() |
MLMessage |
AbstractProcess.sendRequestAndWait(String performative,
String act,
URLDescriptor reciever,
String... list)
Utility method to construct and send a syncronous message using
AbstractProcess.sendRequestAndWait(MLMessage, long, MessageEventDescriptor...) . |
MLMessage |
MLMessage.setParameters(String... list)
Adds a parameters to a MLMessage from an array of Strings, which is
interpreted as key/value pairs.
|
Modifier and Type | Method and Description |
---|---|
Pair<URLDescriptor,MLMessage> |
MLMessage.extractBasicProxyInformation()
Attempts to decode the proxy information from the content field into a
URLDescriptor and an MLMessage . |
static Pair<URLDescriptor,MLMessage> |
MLMessage.extractBasicProxyInformation(String contents)
Attempts to decode the proxy information from the string provided into a
URLDescriptor and an MLMessage . |
Pair<List<URLDescriptor>,MLMessage> |
CooperationDomain.extractCDProxyInformation(String content)
Using the content parameter, parse out the members to forward
a message to.
|
Pair<String,MLMessage> |
MLMessage.extractProxyInformation()
|
static Pair<String,MLMessage> |
MLMessage.extractProxyInformation(String contents)
|
List<MLMessage> |
StatusMLMessageList.getMessages() |
protected StatusObject<MLMessage> |
AbstractProcess.sendMessageAndWait(MLMessage message,
long timeout,
MessageEventDescriptor... messageDescriptors)
Sends a message, message, waiting up to timeout milliseconds
for the request transaction to complete, and returns as StatusObject which contains
the final message, if it completed.
|
protected StatusObject<MLMessage> |
AbstractProcess.sendQueryAndWait(MLMessage message,
long timeout,
MessageEventDescriptor... messageDescriptors)
Sends a QUERY (QUERY-REF or QUERY-IF) message, message, waiting up to timeout milliseconds
for the query transaction to complete, and returns as StatusObject which contains
the final message, if it completed.
|
protected StatusObject<MLMessage> |
AbstractProcess.sendRequestAndWait(MLMessage message,
long timeout,
MessageEventDescriptor... messageDescriptors)
Sends a REQUEST message, message, waiting up to timeout milliseconds
for the request transaction to complete, and returns as StatusObject which contains
the final message, if it completed.
|
Modifier and Type | Method and Description |
---|---|
protected PerformDescriptor |
TransientAgent.accept_deleteCD(MLMessage msg)
Called when a CD this agent is a member of is in the process of exiting:
the behaviour is to withdraw from that CD.
|
PerformDescriptor |
TransientAgent.accept_exit(MLMessage msg)
Process an incoming inform message for a exit act.
|
protected PerformDescriptor |
TransientAgent.accept_forward_message(MLMessage m)
Responds to a received forward.message inform message by passing on the
message encapsulated in the content part of the message.
|
protected PerformDescriptor |
TransientAgent.accept_LAC_closing(MLMessage m)
Responds to a received
inform / LAC_closing inform message by passing on the message encapsulated in the
content part of the message. |
protected PerformDescriptor |
TransientAgent.accept_new_MenuItem(MLMessage message)
The code for responding to an
inform message. |
protected PerformDescriptor |
LAC.accept_UnregisterAgentInstance(MLMessage message)
Handler for an unregister.instance message that has an
inform performative.
|
protected PerformDescriptor |
TransientAgent.accept_update(MLMessage message) |
protected PerformDescriptor |
TransientAgent.acceptDefault(MLMessage message)
The default code for responding to an outging
agree
message. |
private void |
TransientAgent.addRequest(MLMessage msg)
Inserts msg input this list of outstanding requests.
Precondition: msg needs to be a subtype of ML.REQUEST or ML.ACCEPT_PROPOSAL . |
protected void |
CooperationDomain.archiveMessage(MLMessage message)
Stores the given message in this cooperation domain's history node.
|
protected PerformDescriptor |
TransientAgent.assembleDefault(MLMessage message)
The default code for dealing with a
proxy message. |
protected PerformDescriptor |
CooperationDomain.assembleDefault(MLMessage message) |
protected boolean |
TransientAgent.authorizedByProxy(MLMessage msg) |
boolean |
TransientAgent.authorizeMessage(MLMessage msg) |
boolean |
AbstractProcess.authorizeMessage(MLMessage msg)
Determines whether the given message should be handled by receiveMessage,
or if it should be thrown out.
|
private PerformDescriptor |
TransientAgent.callHandlerMethod(MLMessage message,
String methodName)
Calls a method on
this with the specified name, passing it the
given MLMesssage, and returning a PerformDescriptor. |
protected PerformDescriptor |
CooperationDomain.conclude_membership_change(MLMessage message) |
protected PerformDescriptor |
TransientAgent.concludeDefault(MLMessage message)
The default code for responding to a
reply-proposal message. |
PerformDescriptor |
TransientAgent.consider_execute(MLMessage message)
The code for responding to an
request message. |
protected PerformDescriptor |
TransientAgent.consider_invite_to_cd(MLMessage message)
The code for responding to an
request message. |
protected PerformDescriptor |
TransientAgent.consider_new_MenuItem(MLMessage message)
|
PerformDescriptor |
LAC.consider_new_MenuItem(MLMessage message) |
protected PerformDescriptor |
TransientAgent.consider_ping(MLMessage message)
The code for responding to an
request message. |
PerformDescriptor |
CooperationDomain.consider_proxy_message(MLMessage message)
Public method for forwarding proxy messages (I think)
|
PerformDescriptor |
TransientAgent.consider_query_if(MLMessage m)
Responds to a query-ref message by interpreting the act field, attempting
to execute it, and returning a message with the result.
|
PerformDescriptor |
TransientAgent.consider_query_ref(MLMessage m)
Responds to a query-ref message by interpreting the act field, attempting
to execute it, and returning a message with the result.
|
protected PerformDescriptor |
TransientAgent.considerDefault(MLMessage message)
The default code for responding to an
request message or
a ML#PROPOSE_DISCHARGE message. |
static MLMessage |
MLMessage.constructBasicProxyMessage(MLMessage message,
URLDescriptor sender,
URLDescriptor proxyReciever,
URLDescriptor finalReciever) |
static MLMessage |
CooperationDomain.constructCDProxyMessage(MLMessage message,
URLDescriptor sender,
URLDescriptor cd)
Constructs a new proxy message which instructs the cooperation domain to
forward the encapsulated message to all current members of that cooperation
domain.
|
static MLMessage |
CooperationDomain.constructCDProxyMessage(MLMessage message,
URLDescriptor sender,
URLDescriptor cd,
List<URLDescriptor> to,
boolean whisper)
Constructs a new proxy message which instructs the cooperation domain to
forward the encapsulated directed or whisper message.
|
static MLMessage |
CooperationDomain.constructCDProxyMessage(MLMessage message,
URLDescriptor sender,
URLDescriptor cd,
URLDescriptor to,
boolean whisper)
Constructs a new proxy message which instructs the cooperation domain to
forward the encapsulated directed or whisper message.
|
static MLMessage |
MLMessage.constructProxyMessage(MLMessage message,
URLDescriptor sender,
URLDescriptor proxyReciever,
String finalRecieverDescription) |
static MLMessage |
MLMessage.constructReplyTo(MLMessage m,
String replyWith,
URLDescriptor originator)
|
private static byte[] |
SecureProxy.createHash(MLMessage message,
byte[] key,
long uniqueNumber)
Creates a 20 byte hash from the given message, key, and unique number.
|
private String |
SecureProxy.createSignature(MLMessage message)
Creates an signature for the given message.
|
PerformDescriptor |
TransientAgent.dispatchMsgHandlerMethod(String consider,
Act act,
MLMessage message)
This method is called (directly or indirectly) in response to a
request -type message. |
boolean |
MLMessage.equals(MLMessage o) |
PerformDescriptor |
CooperationDomain.evaluate_membership_change(MLMessage message) |
protected PerformDescriptor |
TransientAgent.evaluateDefault(Act act,
MLMessage message) |
PerformDescriptor |
TransientAgent.evesdrop(MLMessage msg)
This is the catch-all method called when
ProcessOptions.observeMessages is set true and the handler method
(the regular method concatonated with "_evesdrop") is not found. |
void |
AbstractProcess.fixupMessage(MLMessage message)
corrects message fields like message timeout if bad
|
protected void |
AgentProxy.forwardMessage(MLMessage message)
Sends the given message to the protected agent at the port given by
agentPort . |
MLMessage |
EventQueue.getMessageInReplyTo(MLMessage msg) |
protected Status |
TransientAgent.handleErrorReplies(MLMessage msg,
String requestType)
Deal with the various error subtypes of reply by constructing an
appropriate Status (with explanation String).
|
protected Status |
SecureProxy.handleForwardMessage(MLMessage message)
Handles all messages that are directed to the protected agent.
|
protected Status |
AgentProxy.handleForwardMessage(MLMessage message)
Handles all messages that should be forwarded to the proxied agent.
|
PerformDescriptor |
CooperationDomainObserver.handleReplies_observeMessages(MLMessage message)
Handles observe.messages subscribe messages.
|
boolean |
AbstractProcess.isAPerformative(MLMessage m,
String ancestor)
Determines if performative field of message m is a subtype of (or the same
type as the performative named by the String performative.
|
boolean |
MLMessage.isReplyTo(MLMessage original) |
protected boolean |
SecureProxy.isSenderAuthorized(MLMessage message)
Determines if the sender of the given message is authorized to send it to
the protected agent, returning
true if the sender is
authorized to send the given message to the protected agent;
false otherwise. |
protected boolean |
SecureProxy.isSenderVerified(MLMessage message)
Verifies the sender of the given message, returning
true if
the sender is verified; false otherwise. |
private MLMessage |
TransientAgent.matchRequest(MLMessage replyRequestMsg)
Finds a request matching (in the
ML.IN_REPLY_TO and
ML.REPLY_WITH fields) and returns the matching message. |
private MLMessage |
TransientAgent.matchRequestAndDelete(MLMessage replyRequestMsg)
Finds a request matching (in the
ML.IN_REPLY_TO and
ML.REPLY_WITH fields), deletes the request from the internal list
of requests and returns the matching message. |
void |
MLMessageReceiver.messageReceived(MLMessage message)
Invoked when a ML message should be received by the object.
|
void |
MessageReceiver.messageReceived(MLMessage message)
This method will be envoked when a message has been received,
message
contains source information and content of the message. |
void |
EventQueue.messageReceived(MLMessage message) |
protected PerformDescriptor |
TransientAgent.monitorDefault(MLMessage message)
The default code for responding to an outging
contract message. |
void |
CommitmentProcessor.notifyMessageSent(MLMessage message)
This method is to be overridden by any subclasses that wish to be informed
whenever a message is actually sent out.
|
protected void |
TransientAgent.notifySendingMessage(MLMessage message)
This method is to be overridden by any subclasses that wish to be informed
whenever a message is actually sent out.
|
protected void |
CooperationDomain.notifySendingMessage(MLMessage message) |
protected void |
AbstractProcess.notifySendingMessage(MLMessage message)
This method is to be overridden by any subclasses that wish to be informed
whenever a message is actually sent out.
|
protected void |
CooperationDomainObserver.observeMessage(MLMessage message) |
PerformDescriptor |
TransientAgent.perform_execute(MLMessage message)
The code for responding to an outgoing
agree message. |
protected PerformDescriptor |
LAC.perform_FindInstances(MLMessage message) |
PerformDescriptor |
TransientAgent.perform_FIPAStyle(MLMessage message) |
PerformDescriptor |
LAC.perform_get_agents_registered(MLMessage msg)
Perform the action for an incoming request message for a getAgentsRegistered act-type request conversation.
|
PerformDescriptor |
LAC.perform_get_agents_running(MLMessage msg)
Perform the action for an incoming request message for a
get_agents_running act-type request conversation.
|
protected PerformDescriptor |
CooperationDomain.perform_get_data(MLMessage message)
Responds to an incoming get.data request message by sending a reply
giving the status of the operation and the requested data.
|
protected PerformDescriptor |
CooperationDomain.perform_get_history(MLMessage message)
Responds to a get.history request using
CooperationDomain.getHistory(URLDescriptor)
to reply. |
PerformDescriptor |
CooperationDomain.perform_get_members(MLMessage message) |
protected PerformDescriptor |
TransientAgent.perform_get_name(MLMessage msg)
Responds to a request from another agent to get this agent's name.
|
protected PerformDescriptor |
TransientAgent.perform_get_ontology(MLMessage message)
The code for responding to an outgoing
agree message. |
protected PerformDescriptor |
TransientAgent.perform_invite_to_cd(MLMessage message)
The code for responding to an outgoing
agree
message. |
PerformDescriptor |
CooperationDomain.perform_join_cd(MLMessage message)
Responds to a join.cd request.
|
protected PerformDescriptor |
TransientAgent.perform_method_call(MLMessage m)
Responds to a received proxy request message by interpreting the content
field, attempting to execute it, and returning a message with the result.
|
protected PerformDescriptor |
CooperationDomain.perform_observe_messages(MLMessage message)
Deprecated.
|
protected PerformDescriptor |
CooperationDomain.perform_put_data(MLMessage message)
Responds to an incoming put.data request message by sending a reply
giving the status of the operation.
|
PerformDescriptor |
TransientAgent.perform_query_if(MLMessage m)
Responds to a query-ref message by interpreting the act field, attempting
to execute it, and returning a message with the result.
|
PerformDescriptor |
TransientAgent.perform_query_ref(MLMessage m)
Responds to a query-ref message by interpreting the act field, attempting
to execute it, and returning a message with the result.
|
PerformDescriptor |
LAC.perform_register_instance(MLMessage msg) |
protected PerformDescriptor |
LAC.perform_RegisterAgentType(MLMessage message)
Handler for a register.agentType message.
|
PerformDescriptor |
LAC.perform_resolve_url(MLMessage message)
Handler for a resolve-url message.
|
protected PerformDescriptor |
LAC.perform_run_agent(MLMessage message) |
protected PerformDescriptor |
LAC.perform_UnregisterAgentInstance(MLMessage message)
Handler for an unregister.instance message that has a
request performative.
|
protected PerformDescriptor |
LAC.perform_UnregisterAgentType(MLMessage message)
Handler for an unregister.agentType message.
|
PerformDescriptor |
CooperationDomain.perform_withdraw_cd(MLMessage message)
Responds to a withdraw.cd request.
|
protected PerformDescriptor |
TransientAgent.performDefault(MLMessage message)
The default code for responding to an outging
agree
message. |
PerformDescriptor |
TransientAgent.release_execute(MLMessage message)
The code for responding to an
propose /
ML.DISCHARGE |... |
PerformDescriptor |
TransientAgent.release_FIPAStyle(MLMessage message) |
PerformDescriptor |
TransientAgent.release_get_agents_registered(MLMessage msg)
Process an incoming propose-discharge or cancel message
for a get_agents_registered act-type request conversation.
|
PerformDescriptor |
TransientAgent.release_get_agents_running(MLMessage msg)
Process an incoming propose-discharge or cancel message
for a getAgentsRunning act-type request conversation.
|
PerformDescriptor |
TransientAgent.release_get_members(MLMessage msg)
Handles get.members replies from a CD.
|
PerformDescriptor |
TransientAgent.release_get_ontology(MLMessage msg)
Handles get.performative replies from another agent.
|
PerformDescriptor |
TransientAgent.release_join_cd(MLMessage msg)
Handles join-cd replies from a CD.
|
protected PerformDescriptor |
CooperationDomain.release_membership_change(MLMessage message) |
protected PerformDescriptor |
TransientAgent.release_ping(MLMessage m)
Responds to a received ping request message by constructing a complimentary
ping reply message and returning it to the sender.
|
PerformDescriptor |
CooperationDomain.release_ping(MLMessage msg)
This method is called when a ping reply message is received in response to a
previously sent ping request message.
|
PerformDescriptor |
TransientAgent.release_query_if(MLMessage m)
Retrieves the response to an earlier query-ref message by interpreting the
act field and content field.
|
PerformDescriptor |
TransientAgent.release_query_ref(MLMessage m)
Retrieves the response to an earlier query-ref message by interpreting the
act field and content field.
|
PerformDescriptor |
TransientAgent.release_resolve_url(MLMessage msg)
An empty placeholder tof the resolve_url conversation.
|
PerformDescriptor |
TransientAgent.release_unregister_agentType(MLMessage msg) |
PerformDescriptor |
TransientAgent.release_unregister_instance(MLMessage msg)
If this messsage is from this agent's LAC (valid :sender field, I'm registered,
TransientAgent.getLACURL() .equals :sender field),
then unregister with the LAC by:
setting setRegisteredWithLAC(false)
setting this agent's URL's LACport to 0
setting the proxy's LACPort to 0
notifying observers ML.EVENT_UNREGISTER_INSTANCE
Setting setBanner(null)
|
PerformDescriptor |
TransientAgent.release_withdraw_cd(MLMessage msg) |
protected PerformDescriptor |
TransientAgent.releaseDefault(MLMessage message)
The default code for responding to a
propose
message. |
protected Status |
TransientAgent.resolveConnectException(MLMessage msg,
Runnable1<String,Status> cmd)
Attempts to resolve the url of the reciever field of a message.
|
protected Status |
AbstractProcess.resolveConnectException(MLMessage msg,
Runnable1<String,Status> cmd)
This method may be overridden by a subclass to handle a ConnectionException
during a call to sendMessage(MLMessage).
|
protected Status |
YellowPagesAgent.respondToAdvertise(MLMessage message) |
protected Status |
YellowPagesAgent.respondToRemoveAdvertisement(MLMessage message) |
protected Status |
YellowPagesAgent.respondToSearch(MLMessage message) |
private Status |
CooperationDomain.sendForwardedMessage(MLMessage message)
Deprecated.
|
(package private) Status |
AbstractProcess.sendMessage_primitive(MLMessage message,
boolean... shouldResolve)
Sends the message to the the message.receiver or, if
message.receiver is missing or empty, to message.to.
|
void |
MLMessageSender.sendMessage(MLMessage message)
Invoked when a ML message needs to be sent.
|
Status |
AbstractProcess.sendMessage(MLMessage message)
Sends the message to the the message.receiver or, if
message.receiver is missing or empty, to message.to.
|
protected StatusObject<MLMessage> |
AbstractProcess.sendMessageAndWait(MLMessage message,
long timeout,
MessageEventDescriptor... messageDescriptors)
Sends a message, message, waiting up to timeout milliseconds
for the request transaction to complete, and returns as StatusObject which contains
the final message, if it completed.
|
protected StatusObject<MLMessage> |
AbstractProcess.sendQueryAndWait(MLMessage message,
long timeout,
MessageEventDescriptor... messageDescriptors)
Sends a QUERY (QUERY-REF or QUERY-IF) message, message, waiting up to timeout milliseconds
for the query transaction to complete, and returns as StatusObject which contains
the final message, if it completed.
|
protected StatusObject<MLMessage> |
AbstractProcess.sendRequestAndWait(MLMessage message,
long timeout,
MessageEventDescriptor... messageDescriptors)
Sends a REQUEST message, message, waiting up to timeout milliseconds
for the request transaction to complete, and returns as StatusObject which contains
the final message, if it completed.
|
private static void |
MLMessage.setIf(MLMessage m,
String key,
String newVal)
Sets the parameter of the message only if the given string is not
null . |
protected Status |
TransientAgent.setInstancesFound(MLMessage message) |
Boolean |
TransientAgent.shouldDoExecuteRequest(MLMessage message)
Determines if we should execute the contents of a request/execute incomming
message.
|
protected void |
SecureProxy.signMessage(MLMessage message)
Digitally signs the given message by creating a unique signature for the
given message and then attaching that signature to the message.
|
protected Status |
TransientAgent.template_handleNewOntologyInfo(MLMessage msg,
String types)
Template method called by handleReply_GetTypes() to do whatever the agent
wants to do with the new type information.
|
protected void |
AbstractProcess.unhandledMessage(MLMessage message)
Subclasses may override this method to override default processing of
unhandled messages.
|
protected boolean |
SecureProxy.universallyAccepted(MLMessage message)
Determines whether the given message is one that should be universally
accepted.
|
protected boolean |
SecureProxy.universallyDenied(MLMessage message)
Determines whether the given message is one that should be universally
denied.
|
protected PerformDescriptor |
TransientAgent.verifyDefault(MLMessage message)
The default code for responding to an non-
request
reply message. |
StatusObject<Object> |
TransientAgent.verifyMessage(MLMessage msg,
String[] list)
Verifies that a message comforms to specification in list.
|
static long |
SecureProxy.verifySignature(MLMessage message,
byte[] key)
Verifies the signature contained in the given message using the given key.
|
Modifier and Type | Method and Description |
---|---|
Status |
TransientAgent.doRegisterAgentInstance(int lacPort,
RunnableWithParameter<MLMessage> successAction,
RunnableWithParameter<MLMessage> failureAction)
Registers this Agent with the LAC.
|
Status |
TransientAgent.doRegisterAgentInstance(int lacPort,
RunnableWithParameter<MLMessage> successAction,
RunnableWithParameter<MLMessage> failureAction)
Registers this Agent with the LAC.
|
void |
StatusMLMessageList.setMessages(List<MLMessage> messages) |
Constructor and Description |
---|
StatusMLMessageList(int status,
List<MLMessage> messages) |
StatusMLMessageList(int status,
String explanation,
List<MLMessage> messages) |
Modifier and Type | Field and Description |
---|---|
private LimitedSet<MLMessage> |
SocketServerTCPIP.recentMessages
A buffer to remember recently received messages to detect possible endless loops of resending messages.
|
private ConcurrentLinkedQueue<Pair<AbstractProcess,MLMessage>> |
TCPChannel.writeQueue
Used to store queued outgoing messages for this connection until the socket is ready to write.
|
Modifier and Type | Method and Description |
---|---|
Pair<AbstractProcess,MLMessage> |
TCPChannel.getNextOutMessage() |
Modifier and Type | Method and Description |
---|---|
private boolean |
SocketServerTCPIP.queueMessage(MLMessage message)
Queue a message that has been read to a (probably) local agent.
|
Status |
URLDescriptor.sendMessage(AbstractProcess sender,
MLMessage message) |
Status |
TCPChannel.sendMessage(AbstractProcess sender,
MLMessage message)
This method doesn't actually immediately send a message right away, but queues the message for
sending once the socket is write-ready.
|
Status |
DirectChannel.sendMessage(AbstractProcess sender,
MLMessage msg) |
Status |
Channel.sendMessage(AbstractProcess sender,
MLMessage msg)
Send a message to the to the agent specified in the RECEIVER field of the msg.
|
Modifier and Type | Method and Description |
---|---|
protected PerformDescriptor |
AuctionCD.conclude_membership_change(MLMessage message) |
PerformDescriptor |
AuctionAgent.conclude_offer_to_sell(MLMessage msg)
Conclude the offer to sell on the auctioneer's end
|
PerformDescriptor |
AuctionAgent.consider_auction_is_over(MLMessage msg)
Perform offer_to_sell (SERVER)
|
PerformDescriptor |
AuctionAgent.consider_auction_starting(MLMessage msg)
Does this agent want the item up for sale?
|
PerformDescriptor |
AuctionAgent.release_get_members(MLMessage msg)
If this agent is the only one left in the CD, no one wants the item on the block
|
PerformDescriptor |
AuctionAgent.release_make_auction_cd(MLMessage msg)
Release when an CD in which to conduct an auction has been created
|
PerformDescriptor |
AuctionAgent.release_offer_to_sell(MLMessage msg)
Release the offer to sell on the bidder's end
|
abstract void |
AuctionAgent.startAuction(MLMessage msg) |
Modifier and Type | Method and Description |
---|---|
PerformDescriptor |
DutchAuctionAgent.consider_offer_to_sell(MLMessage msg)
Consider offer_to_sell (CLIENT)
|
PerformDescriptor |
DutchAuctionAgent.perform_offer_to_sell(MLMessage msg)
Perform offer_to_sell (SERVER)
|
void |
DutchAuctionAgent.startAuction(MLMessage msg) |
Modifier and Type | Field and Description |
---|---|
private MLMessage |
EnglishAuctionAgent.currentBidMessage |
Modifier and Type | Method and Description |
---|---|
PerformDescriptor |
EnglishAuctionAgent.consider_i_hear(MLMessage msg)
Consider the current high bid.
|
PerformDescriptor |
EnglishAuctionAgent.consider_offer_to_sell(MLMessage msg)
Consider offer_to_sell (CLIENT)
|
PerformDescriptor |
EnglishAuctionAgent.perform_offer_to_sell(MLMessage msg)
Perform offer_to_sell (SERVER)
|
void |
EnglishAuctionAgent.startAuction(MLMessage msg)
Inherited from the abstract AuctionAgent class
|
Modifier and Type | Method and Description |
---|---|
PerformDescriptor |
SealedBidAuctionAgent.consider_offer_to_sell(MLMessage msg)
Consider offer_to_sell (CLIENT)
|
PerformDescriptor |
SealedBidAuctionAgent.perform_offer_to_sell(MLMessage msg)
Perform offer_to_sell (SERVER)
|
void |
SealedBidAuctionAgent.startAuction(MLMessage msg)
Inherited from the abstract AuctionAgent class
|
Modifier and Type | Method and Description |
---|---|
PerformDescriptor |
VickreyAuctionAgent.perform_offer_to_sell(MLMessage msg)
Perform offer_to_sell (SERVER)
|
void |
VickreyAuctionAgent.startAuction(MLMessage msg)
Override the SealedBidAuction agent's implementation of the method from the inherited abstract AuctionAgent's class
|
Modifier and Type | Method and Description |
---|---|
PerformDescriptor |
ConversationInterface.callHandlerMethod(MLMessage message,
String methodName)
Calls a method on
this with the specified name, passing it
the given MLMesssage, and returning a PerformDescriptor. |
PerformDescriptor |
ConversationInterface.dispatchMsgHandlerMethod(String consider,
Act act,
MLMessage message)
This method is called (directly or indirectly) in response to a
request -type message. |
PerformDescriptor |
ConversationInterface.dispatchMsgHandlerMethod(String consider,
Act act,
MLMessage message,
boolean contextual) |
PerformDescriptor |
ConversationInterface.eavesdrop(MLMessage msg)
This is the catch-all method called when
ProcessOptions.observeMessages
is set true and the handler method (the regular method concatenated with
"_evesdrop") is not found. |
PerformDescriptor |
SubscribeServerConversation.evaluate_subscribe(MLMessage msg) |
PerformDescriptor |
SubscribeClientConversation.update_subscribe(MLMessage msg) |
Constructor and Description |
---|
Conversation(String name,
TransientAgent ownerAgent,
MLMessage message,
Pair<String,Object>... bindings)
Constructor for a conversation instance.
|
Modifier and Type | Method and Description |
---|---|
private void |
TimeSuper.addParameter(MLMessage msg,
StringBuffer buffer,
ArrayList<String> list,
String key) |
private String |
TimeSuper.messagePrint(MLMessage msg) |
PerformDescriptor |
TimeGiver.perform_getTime(MLMessage message) |
PerformDescriptor |
TimeRequester.release_getTime(MLMessage message) |
Status |
TimeSuper.sendMessage(MLMessage msg) |
Modifier and Type | Field and Description |
---|---|
protected MLMessage |
MessageObserverEvent.message |
private MLMessage |
MessageEvent.message |
Modifier and Type | Method and Description |
---|---|
MLMessage |
MessageObserverEvent.getMessage() |
MLMessage |
MessageEvent.getMessage() |
Modifier and Type | Method and Description |
---|---|
void |
MessageEvent.setMessage(MLMessage message) |
Constructor and Description |
---|
MessageEvent(String newType,
PolicyAgentInterface agent,
MLMessage msg)
Create a new MessageEvent
|
Modifier and Type | Method and Description |
---|---|
MLMessage |
ProcessInterface.getNewMessage(String performative,
String act,
URLDescriptor reciever)
Creates a basic message with the given performative, act, and receiver.
|
MLMessage |
SecurityFilterInterface.processMessage(MLMessage msg,
PolicyAgentInterface agent,
boolean incoming) |
Modifier and Type | Method and Description |
---|---|
void |
ChatAgentInterface.chatMessage(URLDescriptor cd,
MLMessage message)
Performs operations necessary when a chat message has been received.
|
PerformDescriptor |
PolicyAgentInterface.dispatchMsgHandlerMethod(String consider,
Act act,
MLMessage message) |
PerformDescriptor |
PolicyAgentInterface.evesdrop(MLMessage msg)
This is the catch-all method called when
ProcessOptions.observeMessages
is set true and the handler method (the regular method concatenated with
"_evesdrop") is not found. |
abstract Status |
WaitingRequest.handleReply(MLMessage msg) |
boolean |
PolicyAgentInterface.isAPerformative(MLMessage msg,
String p2) |
MLMessage |
SecurityFilterInterface.processMessage(MLMessage msg,
PolicyAgentInterface agent,
boolean incoming) |
PerformDescriptor |
TransientAgentInterface.release_get_ontology(MLMessage msg)
Handles get.performative replies from another agent.
|
Status |
ProcessInterface.sendMessage(MLMessage message)
Sends the message to the the message.receiver or, if
message.receiver is missing or empty, to message.to.
|
Status |
PolicyAgentInterface.sendMessage(MLMessage message)
Sends the message to the the message.receiver or, if
message.receiver is missing or empty, to message.to.
|
Status |
MessageSender.sendMessage(MLMessage message)
This method will be envoked when a message is to be sent,
message
contains destination information about the message. |
Modifier and Type | Method and Description |
---|---|
Status |
TransientAgentInterface.doRegisterAgentInstance(int port,
RunnableWithParameter<MLMessage> successAction,
RunnableWithParameter<MLMessage> failureAction)
Registers with the LAC that this Agent is running.
|
Status |
TransientAgentInterface.doRegisterAgentInstance(int port,
RunnableWithParameter<MLMessage> successAction,
RunnableWithParameter<MLMessage> failureAction)
Registers with the LAC that this Agent is running.
|
Modifier and Type | Method and Description |
---|---|
AbsContentElement |
ContentManager.extractAbsContent(MLMessage msg)
Deprecated.
Translates the
:content slot of an
ACLMessage msg into an AbsContentElement
using the content language and ontology indicated in the
:language and :ontology fields of msg . |
Modifier and Type | Method and Description |
---|---|
SocialCommitmentOperator |
Rule.process(MLMessage message,
PolicyAgentInterface agent) |
Modifier and Type | Method and Description |
---|---|
MLMessage |
SecurityFilter.processMessage(MLMessage msg,
PolicyAgentInterface agent,
boolean incoming) |
Modifier and Type | Method and Description |
---|---|
MLMessage |
SecurityFilter.processMessage(MLMessage msg,
PolicyAgentInterface agent,
boolean incoming) |
Modifier and Type | Method and Description | ||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
Status |
ServiceAgent.ServiceCommand.execute(MLMessage msg) |
||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
Status |
ServiceAgent.handleReplys_observeMembership(MLMessage msg)
Handles observe.membership subscribe messages by first calling the
super method, and then sending this objects service offer to the newly
joined agent.
The handled messages are of the form: Uses of MLMessage in casa.socialcommitments
Uses of MLMessage in casa.socialcommitments.operators
Uses of MLMessage in casa.testAgents
Uses of MLMessage in casa.transaction
Uses of MLMessage in casa.ui
Uses of MLMessage in iRobotCreate
|