diff --git a/keyserver/src/creators/message-creator.js b/keyserver/src/creators/message-creator.js
--- a/keyserver/src/creators/message-creator.js
+++ b/keyserver/src/creators/message-creator.js
@@ -475,14 +475,14 @@
   const [pushInfo] = await Promise.all([
     promiseAll(userPushInfoPromises),
     createReadStatusUpdates(latestMessages),
-    redisPublish(viewer, messageInfosPerUser, updatesForCurrentSession),
+    messageBrokerPublish(viewer, messageInfosPerUser, updatesForCurrentSession),
     updateLatestMessages(latestMessages),
   ]);
 
   await sendPushNotifs(_pickBy(Boolean)(pushInfo));
 }
 
-async function redisPublish(
+async function messageBrokerPublish(
   viewer: Viewer,
   messageInfosPerUser: { [userID: string]: $ReadOnlyArray<RawMessageInfo> },
   updatesForCurrentSession: UpdatesForCurrentSession,
diff --git a/keyserver/src/creators/update-creator.js b/keyserver/src/creators/update-creator.js
--- a/keyserver/src/creators/update-creator.js
+++ b/keyserver/src/creators/update-creator.js
@@ -378,7 +378,10 @@
   }
 
   if (publishInfos.size > 0) {
-    promises.redis = redisPublish(publishInfos.values(), dontBroadcastSession);
+    promises.messageBroker = messageBrokerPublish(
+      publishInfos.values(),
+      dontBroadcastSession,
+    );
   }
 
   if (deleteSQLConditions.length > 0) {
@@ -713,7 +716,7 @@
   updateTarget: UpdateTarget,
   rawUpdateInfos: RawUpdateInfo[],
 };
-async function redisPublish(
+async function messageBrokerPublish(
   publishInfos: Iterator<PublishInfo>,
   dontBroadcastSession: ?string,
 ): Promise<void> {