lib/alephant/publisher/publish_task.rb in alephant-publisher-0.1.4 vs lib/alephant/publisher/publish_task.rb in alephant-publisher-0.1.5

- old
+ new

@@ -16,10 +16,10 @@ @opts = opts end def call unless message.nil? - Writer.new(opts).write(message) + Writer.new(opts, message).run! message.delete end end end