incoming_message.h

// Copyright Maciej Sobczak 2008-2022.
// This file is part of YAMI4.
// See the package-level LICENSE.txt file.
 
#ifndef YAMICPP_INCOMING_MESSAGE_H_INCLUDED
#define YAMICPP_INCOMING_MESSAGE_H_INCLUDED
 
#include "parameters.h"
#include <yami4-core/dll.h>
#include <string>
#include <vector>
 
namespace yami
{
 
namespace details
{
class agent_impl;
struct incoming_message_info;
} // namespace details
 
class DLL incoming_message
{
public:
    incoming_message(details::agent_impl & agent,
        details::incoming_message_info & info);
 
    incoming_message(incoming_message & other);
 
    ~incoming_message();
 
    const std::string & get_source() const;
 
    const std::string & get_object_name() const;
 
    const std::string & get_message_name() const;
 
    const parameters & get_header() const;
 
    const parameters & get_parameters() const;
 
    parameters * extract_parameters();
 
    const std::vector<char> & get_raw_content() const;
 
    long long get_message_id() const;
 
    void reply(const serializable & body = parameters(),
        std::size_t priority = 0);
 
    void reject(const std::string & reason = std::string(),
        std::size_t priority = 0);
 
private:
    incoming_message(const incoming_message &);
    void operator=(const incoming_message &);
 
    details::agent_impl & agent_;
    std::string source_;
    std::string object_name_;
    std::string message_name_;
    long long message_id_;
    core::parameters * core_header_;
    mutable parameters * header_wrapper_; // lazy initialized
    parameters * params_;
    std::vector<char> * raw_buffer_;
    bool already_used_;
};
 
} // namespace yami
 
#endif // YAMICPP_INCOMING_MESSAGE_H_INCLUDED