EventQueueImpl.h

Go to the documentation of this file.

#ifndef EVENTQUEUEIMPL_H_48027643
#define EVENTQUEUEIMPL_H_48027643

#include "uscxml/Common.h"
#include "uscxml/messages/Event.h"
#include <string>
#include <map>
#include <list>
#include <thread>
#include <mutex>
#include <condition_variable>


namespace uscxml {

class USCXML_API EventQueueImpl {
public:
    virtual std::shared_ptr<EventQueueImpl> create() = 0;
    virtual Event dequeue(size_t blockMs) = 0;
    virtual void enqueue(const Event& event) = 0;
    virtual void reset() = 0;
    virtual Data serialize() = 0;
    virtual void deserialize(const Data& data) = 0;
};

class USCXML_API DelayedEventQueueCallbacks {
public:
    virtual void eventReady(Event& event, const std::string& eventId) = 0;
};

class USCXML_API DelayedEventQueueImpl : public EventQueueImpl {
public:
    virtual std::shared_ptr<DelayedEventQueueImpl> create(DelayedEventQueueCallbacks*) = 0;
    virtual void enqueueDelayed(const Event& event, size_t delayMs, const std::string& eventUUID) = 0;
    virtual void cancelDelayed(const std::string& eventId) = 0;
    virtual void cancelAllDelayed() = 0;

    virtual Data serialize() = 0;
    virtual void deserialize(const Data& data) = 0;

private:
    // this will silence the warning about the hidden overloaded virtual function
    using EventQueueImpl::create;
};

}

#endif /* end of include guard: EVENTQUEUEIMPL_H_48027643 */