lib/fluent/plugin/out_sns.rb in fluent-plugin-sns-0.1.0 vs lib/fluent/plugin/out_sns.rb in fluent-plugin-sns-0.1.1
- old
+ new
@@ -42,11 +42,10 @@
def emit(tag, es, chain)
chain.next
es.each {|time,record|
record["time"] = Time.at(time).localtime
subject = record[@sns_subject_key] || @sns_subject || 'Fluent-Notification'
- msg = @topic.publish(record.to_json, :subject => subject )
- $stderr.puts "published topic: #{msg}"
+ @topic.publish(record.to_json, :subject => subject )
}
end
end
end