diff --git a/src/backend/replication/slot.c b/src/backend/replication/slot.c
index 698be8f581a..3c5cb72b1c2 100644
--- a/src/backend/replication/slot.c
+++ b/src/backend/replication/slot.c
@@ -690,7 +690,7 @@ ReplicationSlotDropPtr(ReplicationSlot *slot)
 		char		prefix[MAXPGPATH];
 		snprintf(prefix, sizeof(prefix), "neon-file:%s/state", path);
 		elog(LOG, "Drop replication slot %s", path);
-		LogLogicalMessage(prefix, NULL, 0, false);
+		XLogFlush(LogLogicalMessage(prefix, NULL, 0, false));
 	}
 
 	/*
@@ -1665,7 +1665,7 @@ SaveSlotToPath(ReplicationSlot *slot, const char *dir, int elevel)
 		char		prefix[MAXPGPATH];
 		snprintf(prefix, sizeof(prefix), "neon-file:%s", path);
 		elog(LOG, "Save replication slot at %s restart_lsn=%X/%X", path, 	LSN_FORMAT_ARGS(cp.slotdata.restart_lsn));
-		LogLogicalMessage(prefix, (char*)&cp, sizeof cp, false);
+		XLogFlush(LogLogicalMessage(prefix, (char*)&cp, sizeof cp, false));
 	}
 
 	errno = 0;