lib/alephant/publisher/queue/sqs_helper/archiver.rb in alephant-publisher-queue-1.3.5 vs lib/alephant/publisher/queue/sqs_helper/archiver.rb in alephant-publisher-queue-1.3.6
- old
+ new
@@ -22,31 +22,16 @@
private
def async_store(m)
Thread.new { store(m) }
- logger.metric(
- "AsynchronouslyArchivedData",
- opts[:dimensions].merge(:function => "async_store")
- )
+ logger.metric "AsynchronouslyArchivedData"
end
def store(m)
- logger.metric(
- "SynchronouslyArchivedData",
- opts[:dimensions].merge(:function => "store")
- )
+ logger.metric "SynchronouslyArchivedData"
logger.info "Publisher::Queue::SQSHelper::Archiver#store: '#{m.body}' at 'archive/#{date_key}/#{m.id}'"
cache.put("archive/#{date_key}/#{m.id}", m.body, meta_for(m))
- end
-
- def opts
- {
- :dimensions => {
- :module => "AlephantPublisherQueueSQSHelper",
- :class => "Archiver"
- }
- }
end
def date_key
DateTime.now.strftime('%d-%m-%Y_%H')
end