From 3149a1760dad24b957e2131eb523dc744dda38aa Mon Sep 17 00:00:00 2001
From: Commitfest Bot <cfbot@cputube.org>
Date: Thu, 5 Jun 2025 20:37:20 +0000
Subject: [PATCH] [PATCH]: ./register_notice_process.patch

---
 .../replication/libpqwalreceiver/libpqwalreceiver.c       | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/src/backend/replication/libpqwalreceiver/libpqwalreceiver.c b/src/backend/replication/libpqwalreceiver/libpqwalreceiver.c
index 7b4ddf7a8f52..fa6fa790d1aa 100644
--- a/src/backend/replication/libpqwalreceiver/libpqwalreceiver.c
+++ b/src/backend/replication/libpqwalreceiver/libpqwalreceiver.c
@@ -127,6 +127,12 @@ _PG_init(void)
 	WalReceiverFunctions = &PQWalReceiverFunctions;
 }
 
+static void
+notice_processor(void *arg, const char *message)
+{
+	elog(LOG, "%s", message);
+}
+
 /*
  * Establish the connection to the primary server.
  *
@@ -253,6 +259,8 @@ libpqrcv_connect(const char *conninfo, bool replication, bool logical,
 		PQclear(res);
 	}
 
+	PQsetNoticeProcessor(conn->streamConn, notice_processor, NULL);
+
 	conn->logical = logical;
 
 	return conn;