Package | Description |
---|---|
com.aimpulse.spectrum.core |
Aimpulse platform
|
com.aimpulse.spectrum.core.mts |
Message transport service for the Aimpulse platform
|
com.aimpulse.spectrum.events |
Events for the Aimpulse platform
|
com.aimpulse.spectrum.mas.fipa.protocols |
FIPA protocols
|
com.aimpulse.spectrum.mas.messaging |
Agent communication
|
Modifier and Type | Method and Description |
---|---|
Message |
CommunicativeAgent.receive() |
Message |
CommunicativeAgent.receive(MessagePattern pattern) |
Message |
CommunicativeAgent.send(Message message) |
Modifier and Type | Method and Description |
---|---|
Message |
CommunicativeAgent.send(Message message) |
Modifier and Type | Method and Description |
---|---|
Message |
Inbox.first()
Returns the first message in this inbox.
|
Message |
Inbox.pollFirst()
Polls (retrieves and removes) the first message from this inbox.
|
Message |
AgentMessagingClient.receive() |
Message |
AgentMessagingClient.receive(MessagePattern pattern) |
Message |
AgentMessagingClient.send(Message message) |
Modifier and Type | Method and Description |
---|---|
Iterator<Message> |
Inbox.iterator()
Returns an iterator that iterates the inbox in deterministic order of addition.
|
Modifier and Type | Method and Description |
---|---|
void |
Inbox.add(Message message,
Timestamp receiptStamp)
Adds a message to this inbox.
|
void |
Inbox.remove(Message message)
Removes the given message from this inbox.
|
void |
SimpleMTS.send(Message message) |
void |
MessageTransportService.send(Message message)
Asynchronously sends a message to the receivers stated in the message.
|
Message |
AgentMessagingClient.send(Message message) |
Modifier and Type | Method and Description |
---|---|
Message |
Event.getMessage()
The message contained in this event, if any.
|
Constructor and Description |
---|
Event(Timestamp timestamp,
Message message)
Constructs a message event with a timestamp and a contained message.
|
Modifier and Type | Method and Description |
---|---|
Message |
ContractNetResponder.MessageAccess.getAcceptance()
Returns the acceptance of the initiator.
|
Message |
ContractNetResponder.MessageAccess.getCfp()
Returns the original call-for-proposals.
|
Message |
ContractNetInitiator.MessageAccess.getMessage()
Returns an incoming message to be handled.
|
Message |
RequestInitiator.MessageAccess.getMessage()
Returns an incoming message to be handled.
|
Message |
ContractNetResponder.MessageAccess.getProposal()
Returns the proposal sent to the initiator.
|
Message |
RequestResponder.MessageAccess.getRequest()
Returns the original request.
|
Message |
RequestResponder.MessageAccess.getResponse()
Returns the response to the original request.
|
Modifier and Type | Method and Description |
---|---|
List<Message> |
ContractNetInitiator.MessageAccess.getAllResponses()
Returns an unmodifiable list of all responses to be handled.
|
List<Message> |
RequestInitiator.MessageAccess.getAllResponses()
Returns an unmodifiable list of all responses to be handled.
|
List<Message> |
ContractNetInitiator.MessageAccess.getAllResultNotifications()
Returns an unmodifiable list of all result notifications to be
handled.
|
List<Message> |
RequestInitiator.MessageAccess.getAllResultNotifications()
Returns an unmodifiable list of all result notifications to be
handled.
|
Modifier and Type | Method and Description |
---|---|
ModifiableMessage |
ContractNetResponder.handleAcceptProposal(Message cfp,
Message propose,
Message accept)
This method can be implemented in order to prepare result notifications
after the initiator has accepted a previous proposal.
|
void |
RequestInitiator.handleAgree(Message agree)
This method can be implemented in order to handle agree messages that are
responses to the original request.
|
ModifiableMessage |
ContractNetResponder.handleCfp(Message cfp)
This method can be implemented in order to handle incoming
call-for-proposals.
|
void |
ContractNetInitiator.handleFailure(Message failure)
This method can be implemented in order to handle failure messages that
are result notifications to accepted proposals.
|
void |
RequestInitiator.handleFailure(Message failure)
This method can be implemented in order to handle failure messages that
are responses to the original request.
|
void |
ContractNetInitiator.handleInform(Message inform)
This method can be implemented in order to handle inform messages that
are result notifications to accepted proposals.
|
void |
RequestInitiator.handleInform(Message inform)
This method can be implemented in order to handle inform messages that
are responses to the original request.
|
void |
ContractNetInitiator.handleNotUnderstood(Message notUnderstood)
This method can be implemented in order to handle not-understood messages
that are responses to the original call-for-proposals.
|
void |
RequestInitiator.handleNotUnderstood(Message notUnderstood)
This method can be implemented in order to handle not-understood messages
that are responses to the original request.
|
void |
ContractNetInitiator.handleOutOfSequence(Message message)
This method can be implemented in order to handle messages that arrive
out-of-sequence of the underlying protocol.
|
void |
RequestInitiator.handleOutOfSequence(Message message)
This method can be implemented in order to handle messages that arrive
out-of-sequence of the underlying protocol.
|
void |
ContractNetInitiator.handlePropose(Message propose,
List<ModifiableMessage> acceptances)
This method can be implemented in order to handle propose messages that
are responses to the original call-for-proposals.
|
void |
ContractNetInitiator.handleRefuse(Message refuse)
This method can be implemented in order to handle refuse messages that
are responses to the original call-for-proposals.
|
void |
RequestInitiator.handleRefuse(Message refuse)
This method can be implemented in order to handle refuse messages that
are responses to the original request.
|
void |
ContractNetResponder.handleRejectProposal(Message cfp,
Message propose,
Message reject)
This method can be implemented in order to handle rejections by the
initiator.
|
ModifiableMessage |
RequestResponder.handleRequest(Message request)
This method can be implemented in order to handle incoming requests.
|
ModifiableMessage |
RequestResponder.prepareResultNotification(Message request,
Message response)
This method can be implemented in order to prepare result notifications
for incoming requests.
|
Modifier and Type | Method and Description |
---|---|
void |
RequestInitiator.handleAllResponses(List<Message> responses)
This method can be implemented in order to handle together all responses
(agree, refuse, not-understood) that are responses to the original
request.
|
void |
ContractNetInitiator.handleAllResponses(List<Message> responses,
List<ModifiableMessage> acceptances)
This method can be implemented in order to handle together all responses
(propose, refuse, not-understood) to the original call-for-proposals.
|
void |
ContractNetInitiator.handleAllResultNotifications(List<Message> resultNotifications)
This method can be implemented in order to handle together all result
notifications (inform, failure) to accepted proposals.
|
void |
RequestInitiator.handleAllResultNotifications(List<Message> resultNotifications)
This method can be implemented in order to handle together all result
notifications (inform, failure) that are responses to the original
request.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ModifiableMessage
This interface represents messages that are created by agents
in order to be sent to other agents.
|
Modifier and Type | Class and Description |
---|---|
class |
ReplyMessage
Creates a modifiable message that is a reply
to a previous message.
|
class |
UnmodifiableMessage
This class represents those messages an agent receives
from other agents.
|
Modifier and Type | Method and Description |
---|---|
Message |
Message.clone()
Clones this message.
|
Message |
MessagingClient.receive()
Receives a message if one is available.
|
Message |
MessagingClient.receive(MessagePattern pattern)
Returns a message matching a given pattern if one is available.
|
Message |
MessagingClient.send(Message message)
Sets the sender of the message and passes the message to the message
transport system.
|
Modifier and Type | Method and Description |
---|---|
static MessageBuilder |
MessageBuilder.aReply(Message message,
CommunicativeAct performative)
Creates a builder for modifiable reply messages
|
boolean |
MessagePattern.covers(Message message)
Tests whether this message pattern covers a given message.
|
boolean |
ExampleBasedMessagePattern.covers(Message message) |
void |
XMLMessageWriter.message(Message message) |
void |
MessageHandler.message(Message message)
Informs the handler about a message.
|
static void |
ReplyMessage.prepareReplyConversationControl(Message message,
ModifiableMessage reply)
Prepares a message regarding its conversation control as a reply to an
original message.
|
Message |
MessagingClient.send(Message message)
Sets the sender of the message and passes the message to the message
transport system.
|
String |
XMLMessageSerialization.serialize(Message message) |
String |
MessageSerialization.serialize(Message message)
Serializes a message.
|
Constructor and Description |
---|
ExampleBasedMessagePattern(Message example)
Creates this example-based message pattern.
|
UnmodifiableMessage(AgentIdentifier sender,
Message message)
Instantiates an unmodifiable message from a sender and a message.
|
UnmodifiableMessage(Message message)
Instantiates an unmodifiable message from a message.
|
Copyright © Aimpulse Intelligent Systems GmbH
All rights reserved.