src/semaine/cms/receiver/BytesReceiver.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_BYTESRECEIVER_H
#define SEMAINE_CMS_RECEIVER_BYTESRECEIVER_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/SEMAINEBytesMessage.h>


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

namespace semaine {
namespace cms {
namespace receiver {

class BytesReceiver : public Receiver
{
public:
        BytesReceiver(const std::string & topicName) throw(CMSException) :
                Receiver(topicName)
        {}
        
        BytesReceiver(const std::string & topicName, const std::string & messageSelector)
        throw(CMSException) :
                Receiver(topicName, messageSelector)
        {}

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

        BytesReceiver(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(MessageFormatException)
        {
                return new SEMAINEBytesMessage(message);
        }



};

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


#endif

---