SMRequestorRaw.hpp

Go to the documentation of this file.

#ifndef RAD_SM_REQUESTOR_RAW_HPP
#define RAD_SM_REQUESTOR_RAW_HPP

#include <rad/AnyEvent.hpp>
#include <rad/Dispatcher.hpp>
#include <rad/MsgHandler.hpp>
#include <rad/MsgRequestorRaw.hpp>


namespace rad {

class SMRequestorRaw {

public:
    SMRequestorRaw(const std::string& endpoint,
                   const std::string& identity,
                   boost::asio::io_service& ios,
                   rad::Dispatcher& dispatcher,
                   UniqueEvent&& okEvent,
                   UniqueEvent&& errEvent,
                   UniqueEvent&& timeoutEvent);
    virtual ~SMRequestorRaw();

    size_t Send(const std::string& payloadType,
                const std::string& payload,
                const long timeout = 0);

    void ReplyHandler(const std::error_code& errCode,
                      const std::string& msgTypeId,
                      const void* pData,
                      const size_t dataSize);

    const std::string& GetReplyPayloadType();
    const std::string& GetReplyPayload();

    SMRequestorRaw(const SMRequestorRaw&) = delete;
    SMRequestorRaw& operator= (const SMRequestorRaw&) = delete;

private:
    MsgRequestorRaw    mMsgRequestorRaw;
    rad::Dispatcher&   mDispatcher;
    UniqueEvent        mOkEvent;
    UniqueEvent        mErrEvent;
    UniqueEvent        mTimeoutEvent;
    std::string        mReplyPayloadType;
    std::string        mReplyPayload;
};

} // namespace rad

#endif