fix: prevent attempt to publish 0 messages (#1218)

googleapis · Mar 16, 2021 · 96e6535 · 96e6535
1 parent a4a1513
commit 96e6535
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/publisher/message-queues.ts b/src/publisher/message-queues.ts
@@ -74,6 +74,12 @@ export abstract class MessageQueue extends EventEmitter {
       topic: topic.name,
       messages,
     };
+    if (messages.length === 0) {
+      if (typeof callback === 'function') {
+        callback(null);
+      }
+      return;
+    }
 
     topic.request<google.pubsub.v1.IPublishResponse>(
       {