lib/phobos/actions/process_message.rb in phobos-1.9.0.pre.beta2 vs lib/phobos/actions/process_message.rb in phobos-1.9.0.pre.beta3

@@ -49,10 +49,10 @@
         end
       end
 
       def consume_block(payload, handler)
         proc { |around_payload, around_metadata|
-          if around_payload
+          if around_metadata
             handler.consume(around_payload, around_metadata)
           else
             Phobos.deprecate('Calling around_consume without yielding payload and metadata \
                               is deprecated and will be removed in 2.0.')
             handler.consume(payload, @metadata)