value_publisher.h

// Copyright Maciej Sobczak 2008-2022.
// This file is part of YAMI4.
// See the package-level LICENSE.txt file.
 
#ifndef YAMICPP_VALUE_PUBLISHER_H_INCLUDED
#define YAMICPP_VALUE_PUBLISHER_H_INCLUDED
 
#include "incoming_message_generic_dispatcher.h"
#include "value_publisher_overflow_generic_dispatcher.h"
#include <yami4-core/dll.h>
 
#include <memory>
#include <string>
#include <utility>
#include <vector>
 
namespace yami
{
 
class agent;
class incoming_message;
class serializable;
 
namespace details
{
class value_publisher_impl;
}
 
class DLL value_publisher
{
public:
 
    value_publisher();
 
    ~value_publisher();
 
    template <typename functor>
    value_publisher(functor & f)
    {
        user_command_handler_.reset(
            new details::incoming_message_generic_dispatcher<functor>(f));
        init(user_command_handler_.get());
    }
 
    template <typename incoming_message_functor,
              typename queue_overflow_functor>
    value_publisher(incoming_message_functor & f,
        std::size_t max_queue_length, queue_overflow_functor & qof)
    {
        user_command_handler_.reset(
            new details::incoming_message_generic_dispatcher<
                incoming_message_functor>(f));
        user_overflow_handler_.reset(
            new details::value_publisher_overflow_generic_dispatcher<
                queue_overflow_functor>(qof));
        init(user_command_handler_.get(),
            max_queue_length, user_overflow_handler_.get());
    }
 
    void register_at(agent & controlling_agent,
        const std::string & object_name);
 
    void unregister();
 
    void subscribe(const std::string & destination_target,
        const std::string & destination_object);
 
    void unsubscribe(const std::string & destination_target);
 
    void publish(const serializable & value, std::size_t priority = 0);
 
    std::size_t get_number_of_subscribers() const;
 
    std::vector<std::pair<std::string, std::string> >
    get_subscribers() const;
 
private:
 
    value_publisher(const value_publisher &);
    void operator=(const value_publisher &);
 
    void init(details::incoming_message_dispatcher_base * imd = NULL,
        std::size_t max_queue_length = 1,
        details::value_publisher_overflow_dispatcher_base * qod = NULL);
 
    details::value_publisher_impl * pimpl_;
 
    std::unique_ptr<details::incoming_message_dispatcher_base>
        user_command_handler_;
    std::unique_ptr<details::value_publisher_overflow_dispatcher_base>
        user_overflow_handler_;
};
 
} // namespace yami
 
#endif // YAMICPP_VALUE_PUBLISHER_H_INCLUDED