lib/larva/message_replayer.rb in larva-0.9.2 vs lib/larva/message_replayer.rb in larva-1.0.0
- old
+ new
@@ -22,10 +22,10 @@
if messages.empty?
raise StandardError.new "Message empty"
else
messages.each do |msg|
sqs_message = Propono::SqsMessage.new(msg)
- puts "Message : #{sqs_message}"
+ Filum.logger.info "Message : #{sqs_message}"
sqs.send_message(original_url, sqs_message.to_json_with_exception(StandardError.new "Fake Exception"))
sqs.delete_message(failed_url, msg['ReceiptHandle'])
end
end
end