fixup for 703df25a02be

Author: kelvich

src/pglogical_apply.c

@@ -543,6 +543,7 @@ process_remote_message(StringInfo s, MtmReceiverContext *receiver_ctx)
 				Assert(!receiver_ctx->parallel_allowed);
 				receiver_ctx->parallel_allowed = true;
 			}
+			standalone = true;
 			break;
 		}
 		default:

src/pglogical_proto.c

@@ -819,7 +819,7 @@ MtmReplicationStartupHook(struct PGLogicalStartupHookArgs* args)
 			MtmStateProcessNeighborEvent(MtmReplicationNodeId, MTM_NEIGHBOR_WAL_SENDER_START_RECOVERED, false);
 			LWLockRelease(MtmCommitBarrier);
 
-			XLogFlush(LogLogicalMessage("P", dest_id, strlen(dest_id), false));
+			XLogFlush(LogLogicalMessage("P", dest_id, strlen(dest_id) + 1, false));
 		}
 	}