message_bus.h

Go to the documentation of this file.

 
#pragma once
 
#include <knp/core/message_endpoint.h>
 
#include <functional>
#include <memory>
 
namespace knp::core::messaging::impl
{
class MessageBusImpl;
}  // namespace knp::core::messaging::impl
 
 
namespace knp::core
{
class MessageBus
{
public:
    static MessageBus construct_cpu_bus();
 
    static MessageBus construct_zmq_bus();
 
    static MessageBus construct_bus() { return construct_cpu_bus(); }
 
    MessageBus() = delete;
 
    MessageBus(MessageBus &&) noexcept;
 
    ~MessageBus();
 
public:
    [[nodiscard]] MessageEndpoint create_endpoint();
 
    size_t step();
 
    size_t route_messages();
 
private:
    explicit MessageBus(std::unique_ptr<messaging::impl::MessageBusImpl> &&impl);
 
 
    std::unique_ptr<messaging::impl::MessageBusImpl> impl_;
};
 
}  // namespace knp::core