connect backend before start receiver loop

Andrei Krichinin · Andrei Krichinin · commit f209c5b9a186 · 2022-10-19T13:37:29.000+05:00
diff --git a/src/dmq.c b/src/dmq.c
@@ -1498,6 +1498,8 @@ dmq_receiver_loop(PG_FUNCTION_ARGS)
 #else
 	pg_atomic_write_u64(&MyProc->xmin, InvalidTransactionId);
 #endif
+	dmq_receiver_recreate_mqs(&dmq_state->receivers[receiver_id],
+		  segs, mq_handles);
 
 	for (;;)
 	{

Original file line number	Diff line number	Diff line change
`@@ -1498,6 +1498,8 @@ dmq_receiver_loop(PG_FUNCTION_ARGS)`
`1498`	`1498`	`#else`
`1499`	`1499`	`pg_atomic_write_u64(&MyProc->xmin, InvalidTransactionId);`
`1500`	`1500`	`#endif`
	`1501`	`+ dmq_receiver_recreate_mqs(&dmq_state->receivers[receiver_id],`
	`1502`	`+ segs, mq_handles);`
`1501`	`1503`
`1502`	`1504`	`for (;;)`
`1503`	`1505`	`{`