src/MessageHub.hh

/*
 * This file is part of peekabot.
 *
 * peekabot is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 3 of the License, or
 * (at your option) any later version.
 *
 * peekabot is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */

#ifndef __PEEKABOT_MESSAGE_HUB_HH
#define __PEEKABOT_MESSAGE_HUB_HH


#include <map>
#include <set>
#include <string>
#include <boost/thread/recursive_mutex.hpp>

#include "Types.hh"
#include "Singleton.hh"

namespace peekabot
{

    enum MessageType
    {
        CLIENT_MESSAGE = 0,

        INFO_MESSAGE = 1,

        WARNING_MESSAGE = 2,

        ERROR_MESSAGE = 3,

        DEBUG_MESSAGE = 4,

        LOG_MESSAGE = 5
    };


    class Subscriber;
    class Message;


    class MessageHub
    {
        typedef std::set<Subscriber *> SubscriberSet;

        typedef std::map<MessageType, SubscriberSet> SubscriberMap;

        SubscriberMap m_subscribers;

        mutable boost::recursive_mutex m_mutex;

    public:
        ~MessageHub();

        void publish(
            MessageType type, 
            const std::string &msg, ...) const throw();

        void publish(
            MessageType type, SourceID source, 
            const std::string &msg, ...) const throw();

        void subscribe(MessageType type, Subscriber *recipient) throw();

        void subscribe(Subscriber *recipient) throw();

        void unsubscribe(MessageType type, Subscriber *recipient) throw();

    protected:
        void publish(const Message &message) const throw();
    };



    typedef Singleton<MessageHub> TheMessageHub;


}


#endif // __PEEKABOT_MESSAGE_HUB_HH