src/semaine/cms/receiver/StateReceiver.h

Go to the documentation of this file.

/*
 * StateReceiver.h
 *
 *  Created on: 27.07.2009
 *      Author: marc
 */

#ifndef SEMAINE_CMS_RECEIVER_STATERECEIVER_H
#define SEMAINE_CMS_RECEIVER_STATERECEIVER_H

#include "XMLReceiver.h"

#include <semaine/datatypes/stateinfo/StateInfo.h>
#include <semaine/cms/message/SEMAINEStateMessage.h>
#include <map>

namespace semaine {

namespace cms {

namespace receiver {

class StateReceiver: public semaine::cms::receiver::XMLReceiver {
public:
        StateReceiver(const std::string & topicName, semaine::datatypes::stateinfo::StateInfo::Type datatype) throw(CMSException) :
                XMLReceiver(topicName), stateInfoType(datatype)
        {}

        StateReceiver(const std::string & topicName, const std::string & messageSelector, semaine::datatypes::stateinfo::StateInfo::Type datatype)
        throw(CMSException) :
                XMLReceiver(topicName, messageSelector), stateInfoType(datatype)
        {}


        StateReceiver(const std::string & cmsUrl, const std::string & cmsUser, const std::string & cmsPassword,
                const std::string & topicName, semaine::datatypes::stateinfo::StateInfo::Type datatype)
        throw (CMSException) :
                XMLReceiver(cmsUrl, cmsUser, cmsPassword, topicName), stateInfoType(datatype)
        {}

        StateReceiver(const std::string & cmsUrl, const std::string & cmsUser, const std::string & cmsPassword,
                const std::string & topicName, const std::string & messageSelector, semaine::datatypes::stateinfo::StateInfo::Type datatype)
        throw (CMSException) :
                XMLReceiver(cmsUrl, cmsUser, cmsPassword, topicName, messageSelector), stateInfoType(datatype)
        {}


        virtual ~StateReceiver() {}

        std::string getCurrentBestGuess(const std::string & infoItem);
        virtual void onMessage(const Message * m);


protected:
        virtual semaine::cms::message::SEMAINEMessage * createSEMAINEMessage(const Message * message)
        throw(semaine::cms::exceptions::MessageFormatException)
        {
                return new semaine::cms::message::SEMAINEStateMessage(message, stateInfoType);
        }

private:
        semaine::datatypes::stateinfo::StateInfo::Type stateInfoType;
        std::map<std::string, std::string> currentBestGuess;
        void updateInformationState(semaine::cms::message::SEMAINEMessage * m);

};

}

}

}

#endif /* SEMAINE_CMS_RECEIVER_STATERECEIVER_H */

---