class Pousse::RedisDelivery

Public Class Methods

new(values = {}) click to toggle source
# File lib/pousse/redis_delivery.rb, line 4
def initialize values = {}
  configuration = Pousse::configuration
  @redis_config = configuration.redis
end

Public Instance Methods

deliver!(mail) click to toggle source
# File lib/pousse/redis_delivery.rb, line 9
def deliver!(mail)
  redis = nil
  begin
    redis = Redis.new @redis_config
    mail.to.each do |to|
      redis.publish(to, mail.body.decoded)
    end
  rescue Exception => e
    #TODO: Use a real logguer ??
    puts "NOTIFICATION NOT DELIVERED: #{e.message}"
  ensure
    redis.quit unless redis.nil?
  end
end