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