Sha256: 0bfa1c157bd876e2cdbbfa16bb10ab7ec44f32eb007d91ac6f2856664b4fcecd
Contents?: true
Size: 1.25 KB
Versions: 1
Compression:
Stored size: 1.25 KB
Contents
require 'alephant/logger' require 'date' module Alephant module Publisher module Queue module SQSHelper class Archiver include Logger attr_reader :cache, :async def initialize(cache, async = true) @async = async @cache = cache end def see(message) return if message.nil? message.tap { |m| async ? async_store(m) : store(m) } end private def async_store(m) Thread.new { store(m) } logger.metric "AsynchronouslyArchivedData" end def store(m) 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 date_key DateTime.now.strftime('%d-%m-%Y_%H') end def meta_for(m) { :id => m.id, :md5 => m.md5, :logged_at => DateTime.now.to_s, :queue => m.queue.url, } end end end end end end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
alephant-publisher-queue-1.3.6 | lib/alephant/publisher/queue/sqs_helper/archiver.rb |