| |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
Constructor Summary | |
LightweightConversationManagerImpl(ConversationListener cl, MessageSender ms, FIPAOSAgent agent, DatabaseProfile db_profile, ProtocolProfile protocol_profile) Create and initalise the CM. |
Method Summary | |
Conversation | addConversation(String protocol) Method to create a new conversation given a protcol, and add it to the active list. |
boolean | addProtocol(String protocol_name, String protocol_defn) Adds a new protocol to the CM - this implementation will always return true since protocols are not forced. |
Conversation | getConversation(String conversation_id) Retrieves an active/previous Conversation that an Agent has had |
void | handleMessage(Message msg) Looks at a Message and checks to see if it part of an exisiting conversation. |
boolean | hasProtocol(String protocol) Indicates whether the specified protocol is already in the cache, i.e. |
static void | main(String[] args) |
void | receiveMessage(fipaos.mts.Message msg) |
void | removeConversation(String id) Removes the given conversation from the ConversationManager - this may be necessary in order to end conversations that have no defined end-point |
void | run() When an object implementing interface Runnable is used
to create a thread, starting the thread causes the object's
run method to be called in that separately executing
thread. |
void | sendMessage(Message msg) Attempt to send the message given |
void | setMessageReceiver(MessageReceiver mr) Set the reference to the MessageReceiver that should receive incoming messages |
void | setMessageSender(MessageSender ms) Set the reference to the MessageSender that should send-outgoing messages |
void | shutdown() |
Constructor Detail |
public LightweightConversationManagerImpl(ConversationListener cl, MessageSender ms, FIPAOSAgent agent, DatabaseProfile db_profile, ProtocolProfile protocol_profile)
Method Detail |
public Conversation addConversation(String protocol)
throws fipaos.agent.conversation.UnknownProtocolException
public boolean addProtocol(String protocol_name, String protocol_defn)
public Conversation getConversation(String conversation_id)
throws fipaos.agent.conversation.InvalidConversationIDException
public void handleMessage(Message msg)
throws fipaos.agent.conversation.UnknownProtocolException,
fipaos.agent.conversation.InvalidConversationIDException,
fipaos.agent.conversation.ProtocolErrorException,
fipaos.agent.conversation.ConversationFinishedException
public boolean hasProtocol(String protocol)
public static void main(String[] args)
public void receiveMessage(fipaos.mts.Message msg)
public void removeConversation(String id)
throws fipaos.agent.conversation.InvalidConversationIDException
public void run()
Runnable
is used
to create a thread, starting the thread causes the object's
run
method to be called in that separately executing
thread.
The general contract of the method run
is that it may
take any action whatsoever.
public void sendMessage(Message msg)
public void setMessageReceiver(MessageReceiver mr)
public void setMessageSender(MessageSender ms)
public void shutdown()
Association Links |
to Class fipaos.ont.fipa.fipaman.AgentID
to Class java.lang.String
to Class fipaos.agent.conversation.ConversationListener
to Class fipaos.skill.db.Database
to Class fipaos.util.Monitor
to Class fipaos.agent.FIPAOSAgent
to Class java.util.Map
to Class fipaos.agent.profile.ProtocolProfile
to Class fipaos.mts.MessageSender
to Class java.lang.Thread
to Class fipaos.util.Queue
| |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |