src/semaine/components/Component.h

Go to the documentation of this file.

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

#ifndef SEMAINE_COMPONENTS_COMPONENT_H
#define SEMAINE_COMPONENTS_COMPONENT_H

#include <list>
#include <queue>

#include <semaine/config.h>

#include <decaf/lang/System.h>
#include <decaf/lang/Thread.h>
#include <decaf/util/concurrent/Concurrent.h>
#include <decaf/util/concurrent/Mutex.h>

#include <cms/CMSException.h>

#include <semaine/cms/SEMAINEMessageAvailableListener.h>
#include <semaine/cms/receiver/Receiver.h>
#include <semaine/cms/sender/Sender.h>
#include <semaine/components/meta/MetaMessenger.h>


using namespace decaf::lang;
using namespace cms;
using namespace semaine::cms;
using namespace semaine::cms::receiver;
using namespace semaine::cms::sender;
using namespace semaine::components::meta;

namespace semaine {
namespace components {

class Component : public Thread, public SEMAINEMessageAvailableListener
{
public:
        static const std::string STATE_STARTING;
        static const std::string STATE_READY;
        static const std::string STATE_STOPPED;
        static const std::string STATE_FAILURE;
        static const std::string STATE_STALLED;

        virtual ~Component();

        const std::string getName() { return name; }

        virtual void messageAvailableFrom(Receiver * const source);

        void run();

        void requestExit();



protected:
        std::list<Receiver *> receivers;
        std::list<Sender *> senders;
        std::queue<Receiver *> inputWaiting;
        CMSLogger * log;
        bool _exitRequested;
        std::string state;
        MetaMessenger meta;
        int waitingTime;
        bool isInput;
        bool isOutput;
        decaf::util::concurrent::Mutex mutex;

        Component(const std::string & componentName, bool isInput=false, bool isOutput=false)
        throw (CMSException);

        Component(const std::string & componentName,
                        const std::string & cmsUrl, const std::string & cmsUser = "", const std::string & cmsPassword = "")
        throw (CMSException);

        Component(const std::string & componentName, bool isInput, bool isOutput,
                        const std::string & cmsUrl, const std::string & cmsUser, const std::string & cmsPassword)
        throw (CMSException);

        bool exitRequested();


        virtual void act() throw(std::exception) {}

        virtual void react(SEMAINEMessage * message) throw (std::exception) {}

        virtual void customStartIO() throw(std::exception) {}

private:
        const std::string name;

        void startIO() throw(std::exception);




};




} // namespace components
} // namespace semaine

#endif

---