notification.hxx

Go to the documentation of this file.

/* Definition of the pqxx::notification_receiver functor interface.
 *
 * pqxx::notification_receiver handles incoming notifications.
 *
 * DO NOT INCLUDE THIS FILE DIRECTLY; include pqxx/notification instead.
 *
 * Copyright (c) 2000-2026, Jeroen T. Vermeulen.
 *
 * See COPYING for copyright license.  If you did not receive a file called
 * COPYING with this source code, please notify the distributor of this
 * mistake, or contact the author.
 */
#ifndef PQXX_NOTIFICATION_HXX
#define PQXX_NOTIFICATION_HXX
 
#if !defined(PQXX_HEADER_PRE)
#  error "Include libpqxx headers as <pqxx/header>, not <pqxx/header.hxx>."
#endif
 
#include <string>
 
#include "pqxx/types.hxx"
 
 
namespace pqxx
{
// This code is deprecated.
// LCOV_EXCL_START
 
 
class PQXX_LIBEXPORT PQXX_NOVTABLE notification_receiver
{
public:
 
  [[deprecated("Use pqxx::connection::listen() instead.")]]
  notification_receiver(
    connection &cx, std::string_view channel, sl loc = sl::current());
 
  notification_receiver(notification_receiver const &) = delete;
  notification_receiver(notification_receiver &&) = delete;
 
  virtual ~notification_receiver();
 
  notification_receiver &operator=(notification_receiver const &) = delete;
  notification_receiver &operator=(notification_receiver &&) = delete;
 
  [[nodiscard]] std::string const &channel() const & { return m_channel; }
 
 
  virtual void operator()(std::string const &payload, int backend_pid) = 0;
 
protected:
  [[nodiscard]] connection &conn() const noexcept { return m_conn; }
 
private:
  connection &m_conn;
  std::string m_channel;
};
// LCOV_EXCL_STOP
} // namespace pqxx
#endif