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

@@ -42,12 +42,12 @@
           preprocessed_payload = before_consume(handler, payload)
           consume_block = proc { handler.consume(preprocessed_payload, @metadata) }
 
           if @listener.handler_class.respond_to?(:around_consume)
             # around_consume class method implementation
-            Phobos.deprecate('around_consume has been moved to instance method, '\
-              'please update your consumer. This will not be backwards compatible in the future.')
+            Phobos.deprecate('around_consume has been moved to instance method, please update '\
+                             'your consumer. This will not be backwards compatible in the future.')
             @listener.handler_class.around_consume(preprocessed_payload, @metadata, &consume_block)
           else
             # around_consume instance method implementation
             handler.around_consume(preprocessed_payload, @metadata, &consume_block)
           end
@@ -55,11 +55,12 @@
       end
 
       def before_consume(handler, payload)
         handler.before_consume(payload, @metadata)
       rescue ArgumentError
-        Phobos.deprecate('before_consume now expects metadata as second argument, '\
-          'please update your consumer. This will not be backwards compatible in the future.')
+        Phobos.deprecate('before_consume now expects metadata as second argument, please update '\
+                         'your consumer. This will not be backwards compatible in the future.')
+
         handler.before_consume(payload)
       end
     end
   end
 end