fix error when topic writable queue num is zero

yuz10 · Apr 11, 2024 · b76e77e · b76e77e
1 parent d62d220
commit b76e77e
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/lib/resty/rocketmq/producer.lua b/lib/resty/rocketmq/producer.lua
@@ -139,6 +139,9 @@ local function produce(self, msg, mqSelector)
     if not topicPublishInfo then
         return nil, err
     end
+    if #topicPublishInfo.messageQueueList == 0 then
+        return nil, 'writable queue num is zero'
+    end
     local mqSelected
     if mqSelector == nil then
         mqSelected = selectOneMessageQueue(topicPublishInfo)