lib/alephant/publisher/queue/processor/base.rb in alephant-publisher-queue-2.0.0 vs lib/alephant/publisher/queue/processor/base.rb in alephant-publisher-queue-2.0.1
- old
+ new
@@ -1,13 +1,13 @@
module Alephant
module Publisher
module Queue
class BaseProcessor
-
def consume(msg)
- raise NotImplementedError.new("You must implement the #consume(msg) method")
+ raise NotImplementedError.new(
+ "You must implement the #consume(msg) method"
+ )
end
-
end
end
end
end