publisher.h

#ifndef B0__PUBLISHER_H__INCLUDED
#define B0__PUBLISHER_H__INCLUDED

#include <string>

#include <b0/socket.h>

namespace b0
{

class Node;

class Publisher : public Socket
{
public:
    using logger::LogInterface::log;

    Publisher(Node *node, std::string topic, bool managed = true, bool notify_graph = true);

    virtual ~Publisher();

    void log(LogLevel level, std::string message) const override;

    virtual void init() override;

    virtual void cleanup() override;

    std::string getTopicName();

    virtual void publish(const std::string &msg);

protected:
    virtual void connect();

    virtual void disconnect();

    const bool notify_graph_;
};

} // namespace b0

#endif // B0__PUBLISHER_H__INCLUDED