local_broker.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <mutex>
#include <string>
 
#include "spsp/layers.hpp"
#include "spsp/node.hpp"
#include "spsp/wildcard_trie.hpp"
 
namespace SPSP::FarLayers::LocalBroker
{
    class LocalBroker : public IFarLayer
    {
        std::mutex m_mutex;
        SPSP::WildcardTrie<bool> m_subs;  
        std::string m_topicPrefix;        
 
    public:
        LocalBroker(const std::string topicPrefix = "spsp");
 
        ~LocalBroker();
 
        bool publish(const std::string& src, const std::string& topic,
                     const std::string& payload);
 
        bool subscribe(const std::string& topic);
 
        bool unsubscribe(const std::string& topic);
    };
} // namespace SPSP::FarLayers::LocalBroker