diff --git a/adhoc/issue121_03.rb b/adhoc/issue121_03.rb index 54c9e00..364a65e 100644 --- a/adhoc/issue121_03.rb +++ b/adhoc/issue121_03.rb @@ -122,9 +122,11 @@ def publish @client.publish(@queue, mo, hs) end # if @block - puts "PUB: start user sleep" - sleep @tslt # see issue discussion - puts "PUB: end user sleep" + if nm < @nmsgs + puts "PUB: start user sleep" + sleep @tslt # see issue discussion + puts "PUB: end user sleep" + end $stdout.flush end # @nmsgs.times do