notification.hxx

#ifndef PQXX_H_NOTIFICATION
#define PQXX_H_NOTIFICATION

#include "pqxx/compiler-public.hxx"
#include "pqxx/compiler-internal-pre.hxx"

#include <string>

#include "pqxx/types.hxx"


namespace pqxx
{

class PQXX_LIBEXPORT PQXX_NOVTABLE notification_receiver
{
public:

  notification_receiver(connection_base &c, const std::string &channel);
  notification_receiver(const notification_receiver &) =delete;
  notification_receiver &operator=(const notification_receiver &) =delete;
  virtual ~notification_receiver();

  const std::string &channel() const { return m_channel; }


  virtual void operator()(const std::string &payload, int backend_pid) =0;

protected:
  connection_base &conn() const noexcept { return m_conn; }

private:
  connection_base &m_conn;
  std::string m_channel;
};
}

#include "pqxx/compiler-internal-post.hxx"
#endif