13 #ifndef PQXX_H_NOTIFICATION
14 #define PQXX_H_NOTIFICATION
16 #include "pqxx/compiler-public.hxx"
17 #include "pqxx/internal/compiler-internal-pre.hxx"
21 #include "pqxx/types.hxx"
69 [[nodiscard]] std::string
const &
channel()
const {
return m_channel; }
80 virtual void operator()(std::string
const &payload,
int backend_pid) = 0;
87 std::string m_channel;
91 #include "pqxx/internal/compiler-internal-post.hxx"
The home of all libpqxx classes, functions, templates, etc.
Definition: array.hxx:26
connection & conn() const noexcept
Definition: notification.hxx:83
std::string const & channel() const
The channel that this receiver listens on.
Definition: notification.hxx:69
Connection to a database.
Definition: connection.hxx:164
virtual ~notification_receiver()
Definition: notification.cxx:28
virtual void operator()(std::string const &payload, int backend_pid)=0
Overridable: action to invoke when notification arrives.
notification_receiver & operator=(notification_receiver const &)=delete
notification_receiver(connection &c, std::string_view channel)
Register the receiver with a connection.
Definition: notification.cxx:20
notification_receiver(notification_receiver const &)=delete
Definition: notification.hxx:56