commit 407a506 broke referee recovery. We still need to send transactions with invalidId

Author: kelvich

pglogical_proto.c

@@ -160,7 +160,8 @@ pglogical_write_begin(StringInfo out, PGLogicalOutputData *data,
 		MTM_LOG2("%d: pglogical_write_begin XID=%lld sent", MyProcPid, (long64)txn->xid);
 		pq_sendbyte(out, 'B');		/* BEGIN */
 		pq_sendint(out, MtmNodeId, 4);
-		pq_sendint64(out, txn->xid);
+		// pq_sendint64(out, txn->xid);
+		pq_sendint64(out, isRecovery ? InvalidTransactionId : txn->xid);
 		pq_sendint64(out, csn);
 		pq_sendint64(out, participantsMask);