commit 99d4318bf605be07b6393c7ecc5336f0864cd9a5
Author: Masahiko Sawada <sawada.mshk@gmail.com>
Date:   Mon Apr 17 17:27:50 2017 +0900

    Change DatumGetObjectId to DatumGetInt32.

diff --git a/src/backend/replication/logical/worker.c b/src/backend/replication/logical/worker.c
index 656d399..fa4f3b6 100644
--- a/src/backend/replication/logical/worker.c
+++ b/src/backend/replication/logical/worker.c
@@ -1441,7 +1441,7 @@ subscription_change_cb(Datum arg, int cacheid, uint32 hashvalue)
 void
 ApplyWorkerMain(Datum main_arg)
 {
-	int				worker_slot = DatumGetObjectId(main_arg);
+	int				worker_slot = DatumGetInt32(main_arg);
 	MemoryContext	oldctx;
 	char			originname[NAMEDATALEN];
 	XLogRecPtr		origin_startpos;