perf

src/lavinmq/exchange/exchange.cr

@@ -171,11 +171,11 @@ module LavinMQ
       count = 0
       queues.each do |queue|
         if queue.publish(msg)
-          @publish_out_count += 1
           count += 1
           msg.body_io.seek(-msg.bodysize.to_i64, IO::Seek::Current) # rewind
         end
       end
+      @publish_out_count += count
       count
     end
 
@@ -209,8 +209,7 @@ module LavinMQ
       return unless cc = headers[key]?
       cc = cc.as?(Array(AMQP::Field))
 
-      err = Error::PreconditionFailed.new("#{key} header not a string array")
-      raise err unless cc
+      raise Error::PreconditionFailed.new("#{key} header not a string array") unless cc
 
       hdrs = headers.clone
       hdrs.delete "CC"
@@ -219,7 +218,7 @@ module LavinMQ
         if rk = rk.as?(String)
           find_queues(rk, hdrs, queues)
         else
-          raise err
+          raise Error::PreconditionFailed.new("#{key} header not a string array")
         end
       end
     end