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/msgHandler.hpp>
#include <rad/msgRequestorRaw.hpp>
#include <rad/smAdapter.hpp>
 
namespace rad {
 
class SMRequestorRaw {
   public:
    SMRequestorRaw(const std::string& endpoint, const std::string& identity,
                   boost::asio::io_context& ios, SMAdapter& sm, UniqueEvent&& ok_event,
                   UniqueEvent&& err_event, UniqueEvent&& timeout_event);
    virtual ~SMRequestorRaw();
 
    size_t Send(const std::string& payload_type, const std::string& payload,
                const long timeout = 0);
 
    void ReplyHandler(const std::error_code& err_code, const std::string& msg_type_id,
                      const void* data, const size_t data_size);
 
    const std::string& GetReplyPayloadType();
    const std::string& GetReplyPayload();
 
    SMRequestorRaw(const SMRequestorRaw&) = delete;
    SMRequestorRaw& operator=(const SMRequestorRaw&) = delete;
 
   private:
    MsgRequestorRaw m_msg_requestor_raw;
    SMAdapter& m_sm;
    UniqueEvent m_ok_event;
    UniqueEvent m_err_event;
    UniqueEvent m_timeout_event;
    std::string m_reply_payload_type;
    std::string m_reply_payload;
};
 
}  // namespace rad
 
#endif  // RAD_SM_REQUESTOR_RAW_HPP