conversation_monitor.h

Go to the documentation of this file.

#ifndef FIPA_ACL_CONVERSATION_MONITOR_H
#define FIPA_ACL_CONVERSATION_MONITOR_H

#include <map>
#include <vector>
#include <boost/thread/mutex.hpp>

#include <fipa_acl/conversation_monitor/conversation.h>
#include <fipa_acl/message_generator/acl_message.h>

namespace fipa {
namespace acl {

class Configuration;

class ConversationMonitor
{

public: 
    ConversationMonitor(const AgentID& self, const std::string& protocolDirectory = "");

    virtual ~ConversationMonitor();

    ConversationPtr updateConversation(const fipa::acl::ACLMessage& msg);

    ConversationPtr startConversation(const std::string& topic);

    bool removeConversation(const fipa::acl::ConversationID& conversationId);

    ConversationPtr getConversation(const fipa::acl::ConversationID& conversationId);

    ConversationPtr getOrCreateConversation(const fipa::acl::ConversationID& conversationId); 

    void cleanup();
    
    std::vector<fipa::acl::ConversationID> getActiveConversations();

private:
    AgentID mSelf;

    std::map<fipa::acl::ConversationID, ConversationPtr> mActiveConversations;

    boost::mutex mMutex;
};

} // end namespace acl
} // end namespace fipa
#endif // FIPA_ACL_CONVERSATION_MONITOR_H