src/semaine/cms/receiver/FeatureReceiver.h

Go to the documentation of this file.

/*
 *  FeatureReceiver.h
 *  semaine
 *
 *  Created by Marc Schröder on 18.09.08.
 *  Copyright 2008 DFKI GmbH. All rights reserved.
 *
 */

#ifndef SEMAINE_CMS_RECEIVER_FEATURERECEIVER_H
#define SEMAINE_CMS_RECEIVER_FEATURERECEIVER_H

#include <semaine/config.h>

#include <cms/CMSException.h>

#include <semaine/cms/receiver/Receiver.h>
#include <semaine/cms/exceptions/MessageFormatException.h>
#include <semaine/cms/message/SEMAINEFeatureMessage.h>


using namespace cms;
using namespace semaine::cms::message;

namespace semaine {
namespace cms {
namespace receiver {

class FeatureReceiver : public Receiver
{
public:
        FeatureReceiver(const std::string & topicName) throw(CMSException) :
                Receiver(topicName)
        {}

        FeatureReceiver(const std::string & topicName, const std::string & messageSelector)
        throw(CMSException) :
                Receiver(topicName, messageSelector)
        {}

        FeatureReceiver(const std::string & cmsUrl, const std::string & cmsUser, const std::string & cmsPassword,
                const std::string & topicName)
        throw (CMSException) :
                Receiver(cmsUrl, cmsUser, cmsPassword, topicName)
        {}

        FeatureReceiver(const std::string & cmsUrl, const std::string & cmsUser, const std::string & cmsPassword,
                const std::string & topicName, const std::string & messageSelector)
        throw (CMSException) :
                Receiver(cmsUrl, cmsUser, cmsPassword, topicName, messageSelector)
        {}


protected:
        virtual SEMAINEMessage * createSEMAINEMessage(const Message * message)
        throw(semaine::cms::exceptions::MessageFormatException)
        {
                SEMAINEFeatureMessage * fm = new SEMAINEFeatureMessage(message);
                try {
                        if (featureNames.empty() && fm->hasFeatureNames()) {
                                featureNames = fm->getFeatureNames();
                        } else if (!featureNames.empty() && !fm->hasFeatureNames()) {
                                fm->setFeatureNames(featureNames);
                        }
                } catch (CMSException & e) {
                        std::stringstream buf;
                        buf << "Problem accessing feature names: ";
                        e.printStackTrace(buf);
                        throw semaine::cms::exceptions::MessageFormatException(buf.str());
                }
                return fm;
        }


private:
        std::vector<std::string> featureNames;
};

} // namespace receiver
} // namespace cms
} // namespace semaine


#endif

---