src/semaine/cms/IOBase.h

Go to the documentation of this file.

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

#ifndef SEMAINE_CMS_IOBASE_H
#define SEMAINE_CMS_IOBASE_H

#include <semaine/config.h>

#include <cms/Connection.h>
#include <cms/Session.h>
#include <cms/TextMessage.h>
#include <cms/BytesMessage.h>
#include <cms/MapMessage.h>
#include <cms/CMSException.h>
#include <cms/ExceptionListener.h>
#include <cms/MessageListener.h>
#include <stdlib.h>
#include <iostream>

#include <semaine/cms/event.h>

#include "CMSLogger.h"

using namespace cms;

namespace semaine { 
        namespace cms {

    class ExcListener;


                
                class IOBase {
                protected:
                        const std::string cmsUrl;
                        const std::string cmsUser;
                        const std::string cmsPassword;
                        Connection * connection;
                        Session * session;
                        Topic * topic;
                        bool isConnectionStarted;
                        const CMSException * exception;
                        
                public:
                        IOBase(const std::string & topicName)
                        throw (CMSException);
                        
                        virtual ~IOBase();
                        
                        IOBase(const std::string & cmsUrl, const std::string & cmsUser, const std::string & cmsPassword, const std::string & topicName)
                        throw (CMSException);
                        
                        std::string getTopicName()
                        throw (CMSException);
                        
                        void startConnection()
                        throw (CMSException);
                        
                        std::string getCMSUrl()
                        {
                                return cmsUrl;
                        }
                        
                        Connection* getConnection()
                        {
                                return connection;
                        }
                        
                        Session* getSession()
                        {
                                return session;
                        }
                        
                        Topic* getTopic()
                        {
                                return topic;
                        }
                        
                        
                        
                friend class ExcListener;

                private:
                        void initialise(const std::string & topicName) throw (CMSException);
                        void setException(const CMSException & ex);
                        ExcListener * excListener;

                }; // class IOBase
                

                class ExcListener : public ExceptionListener {
                public:
                        ExcListener(IOBase * iobase) :
                                iobase(iobase)
                        {}
                        virtual void onException(const CMSException & ex) {
                                CMSLogger::getLog("Connection")->error(std::string("Exception Listener: "), &ex);
                        iobase->setException(ex);
                        }
                private:
                        IOBase * iobase;
                };


                
        } // namespace cms
} // namespace semaine
#endif

---