| |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
This class embodies the core functionality of the ConversationManagerImpl.
Constructor Summary | |
ConversationManagerImpl(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 - the CM will attempt to learn the protocol and will cache it for future use. |
Conversation | getConversation(String conversation_id) Retrieves an active/previous Conversation that an Agent has had |
(package private) static String | getProtocolClassName(String protocol) Returns the protocol class name for the protocol passed in to the method. |
void | handleMessage(Message msg) Looks at a Message and checks to see if it part of an exisiting conversation. |
boolean | hasActiveConversations() Indicates whether an Agent has any conversations in active state |
boolean | hasProtocol(String protocol) Indicates whether the specified protocol is already in the cache, i.e. |
static void | main(String[] args) |
void | receiveMessage(Message msg) Received an incoming message - put it through the CM |
void | removeConversation(String conversation_id) Moves a conversation from the Active to the conversation archive |
void | run() Main thread for dealing with non-event based Conversation updates |
void | sendMessage(Message msg) Attempt to send the given message |
void | setMessageReceiver(MessageReceiver p1) Attempt to set the receiver of incoming messages - not supported by this class! |
void | setMessageSender(MessageSender p1) |
static void | setProtocolProfile(ProtocolProfile pp) Method to set the ProtocolProfile for the JVM |
void | shutdown() Shutdown the CM |
Constructor Detail |
public ConversationManagerImpl(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
static String getProtocolClassName(String protocol)
throws fipaos.agent.conversation.UnknownProtocolException
public void handleMessage(Message msg)
throws fipaos.agent.conversation.UnknownProtocolException,
fipaos.agent.conversation.InvalidConversationIDException,
fipaos.agent.conversation.ProtocolErrorException,
fipaos.agent.conversation.ConversationFinishedException
public boolean hasActiveConversations()
public boolean hasProtocol(String protocol)
public static void main(String[] args)
public void receiveMessage(Message msg)
public void removeConversation(String conversation_id)
public void run()
public void sendMessage(Message msg)
public void setMessageReceiver(MessageReceiver p1)
public void setMessageSender(MessageSender p1)
public static void setProtocolProfile(ProtocolProfile pp)
public void shutdown()
Association Links |
to Class fipaos.ont.fipa.fipaman.AgentID
to Class java.util.Map
to Class java.util.Map
to Class fipaos.util.Queue
to Class fipaos.mts.MessageSender
to Class fipaos.agent.FIPAOSAgent
to Class fipaos.agent.conversation.ConversationListener
to Class fipaos.skill.db.Database
to Class java.lang.Thread
to Class fipaos.util.Monitor
to Class fipaos.agent.profile.ProtocolProfile
| |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |