Skip to content

Commit 3b0840a

Browse files
Sasha Krassovskytristan957
authored andcommitted
Prevent output callbacks from hearing about neon-file messages (#330)
* Prevent output callbacks from hearing about neon-file messages
1 parent 1720ed6 commit 3b0840a

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

src/backend/replication/logical/logical.c

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1174,6 +1174,8 @@ message_cb_wrapper(ReorderBuffer *cache, ReorderBufferTXN *txn,
11741174

11751175
if (ctx->callbacks.message_cb == NULL)
11761176
return;
1177+
if (strcmp(prefix, "neon-file") == 0)
1178+
return;
11771179

11781180
/* Push callback + info on the error context stack */
11791181
state.ctx = ctx;
@@ -1489,6 +1491,8 @@ stream_message_cb_wrapper(ReorderBuffer *cache, ReorderBufferTXN *txn,
14891491
/* this callback is optional */
14901492
if (ctx->callbacks.stream_message_cb == NULL)
14911493
return;
1494+
if (strcmp(prefix, "neon-file")) == 0)
1495+
return;
14921496

14931497
/* Push callback + info on the error context stack */
14941498
state.ctx = ctx;

0 commit comments

Comments
 (0)