GWSConnector.h

#pragma once

#include <Poco/SharedPtr.h>
#include <Poco/Timespan.h>

#include "gwmessage/GWMessage.h"
#include "server/GWSListener.h"
#include "util/EventSource.h"

namespace BeeeOn {

class GWSConnector {
public:
        typedef Poco::SharedPtr<GWSConnector> Ptr;

        virtual ~GWSConnector();

        virtual void send(const GWMessage::Ptr message) = 0;

        void addListener(GWSListener::Ptr listener);

        void clearListeners();

        void setEventsExecutor(AsyncExecutor::Ptr executor);

protected:
        template <typename Event, typename Method>
        void fireEvent(const Event &e, const Method &m)
        {
                m_eventSource.fireEvent(e, m);
        }

        void fireReceived(const GWMessage::Ptr message);

private:
        EventSource<GWSListener> m_eventSource;
};

}