EventQueue.h

Go to the documentation of this file.

#ifndef EVENTQUEUE_H_C5C41BEE
#define EVENTQUEUE_H_C5C41BEE

#include "uscxml/Common.h"
#include "uscxml/messages/Event.h"

namespace uscxml {

class EventQueueImpl;
class DelayedEventQueueImpl;

class USCXML_API EventQueue {
public:
    PIMPL_OPERATORS(EventQueue);

    virtual Event dequeue(size_t blockMs);
    virtual void enqueue(const Event& event);
    virtual void reset();

    Data serialize();
    void deserialize(const Data& data);

    virtual std::shared_ptr<EventQueueImpl> getImplBase();

protected:
    std::shared_ptr<EventQueueImpl> _impl;

};

class USCXML_API DelayedEventQueue : public EventQueue {
public:
    PIMPL_OPERATORS_INHERIT(DelayedEventQueue, EventQueue)

    void enqueueDelayed(const Event& event, size_t delayMs, const std::string& eventUUID);
    void cancelDelayed(const std::string& eventUUID);
    void cancelAllDelayed();
    virtual std::shared_ptr<DelayedEventQueueImpl> getImplDelayed();

protected:
    std::shared_ptr<DelayedEventQueueImpl> _impl;
};

}

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