DbListener.h

Go to the documentation of this file.

 
#pragma once
 
#include <drogon/exports.h>
#include <functional>
#include <string>
#include <memory>
 
namespace trantor
{
class EventLoop;
}
 
namespace drogon
{
namespace orm
{
class DbListener;
using DbListenerPtr = std::shared_ptr<DbListener>;

class DROGON_EXPORT DbListener
{
  public:
    using MessageCallback = std::function<void(std::string, std::string)>;
 
    virtual ~DbListener();


    static DbListenerPtr newPgListener(const std::string &connInfo,
                                       trantor::EventLoop *loop = nullptr);


    virtual void listen(const std::string &channel,
                        MessageCallback messageCallback) noexcept = 0;


    virtual void unlisten(const std::string &channel) noexcept = 0;
};
 
}  // namespace orm
}  // namespace drogon