GWSQueuingExporter.h

#pragma once

#include <set>

#include <Poco/Event.h>
#include <Poco/Mutex.h>
#include <Poco/Timespan.h>

#include "core/QueuingExporter.h"
#include "loop/StoppableRunnable.h"
#include "loop/StopControl.h"
#include "server/GWSConnector.h"
#include "server/GWSListener.h"

namespace BeeeOn {

class GWSQueuingExporter :
        public QueuingExporter,
        public StoppableRunnable,
        public GWSListener {
public:
        typedef Poco::SharedPtr<GWSQueuingExporter> Ptr;

        GWSQueuingExporter();

        void setActiveCount(int count);

        void setAcquireTimeout(const Poco::Timespan &timeout);

        void setSendFailedDelay(const Poco::Timespan &delay);

        void setConnector(GWSConnector::Ptr connector);

        void onConnected(const Address &address) override;

        void onOther(const GWMessage::Ptr message) override;

        void run() override;
        void stop() override;
        
private:
        size_t m_activeCount;
        Poco::Timespan m_acquireTimeout;
        Poco::Timespan m_sendFailedDelay;
        GWSConnector::Ptr m_connector;
        StopControl m_stopControl;
        Poco::Event m_event;
        std::set<GlobalID> m_acked;
        Poco::FastMutex m_ackedLock;
};

}