fix consumer listen not stop after listen wait timeout

archfish · Dec 13, 2019 · 0ba0bdb · 0ba0bdb
1 parent 7ceca86
commit 0ba0bdb
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/lib/pulsar_sdk/consumer.rb b/lib/pulsar_sdk/consumer.rb
@@ -96,7 +96,7 @@ def listen(autoack = false)
         flow if all_readed?
 
         cmd, msg = receive(@listen_wait)
-        next if msg.nil?
+        return if msg.nil?
 
         result = yield cmd, msg
 

diff --git a/lib/pulsar_sdk/version.rb b/lib/pulsar_sdk/version.rb
@@ -1,3 +1,3 @@
 module PulsarSdk
-  VERSION = "0.6.6"
+  VERSION = "0.6.7"
 end