Contents

require 'aws-sdk'

module Sqspoller
  class SnsForwarder
    def initialize args
      @sns = Aws::SNS::Client.new access_key_id: args[:access_key_id],
                                  secret_access_key: args[:secret_access_key],
                                  region: args[:region]
      @topic_arn = args[:sns_topic_arn]
      @logger = args[:logger]
      @logger.info "     Inializing SnsForwarder with SNS topic arn: #{@topic_arn}"
    end

    def process message, message_id
      @logger.info "      Processing message"
      @logger.info "        Publishing to #{@topic_arn}"
      response = @sns.publish topic_arn: @topic_arn, message: message
      @logger.info "        SNS response message id: #{response.message_id}"
    end
  end
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version	Path
fk-redis-sqspoller-0.1.2.5.4.alpha	lib/sqspoller/sns_forwarder.rb
fk-redis-sqspoller-0.1.2.5.3.alpha	lib/sqspoller/sns_forwarder.rb
fk-redis-sqspoller-0.1.2.5.2.alpha	lib/sqspoller/sns_forwarder.rb
fk-redis-sqspoller-0.1.2.5.1.alpha	lib/sqspoller/sns_forwarder.rb
fk-redis-sqspoller-0.1.2.5.alpha	lib/sqspoller/sns_forwarder.rb
fk-redis-sqspoller-0.1.2.4.alpha	lib/sqspoller/sns_forwarder.rb
fk-redis-sqspoller-0.1.2.2	lib/sqspoller/sns_forwarder.rb
fk-redis-sqspoller-0.1.2.1	lib/sqspoller/sns_forwarder.rb
fk-redis-sqspoller-0.1.2	lib/sqspoller/sns_forwarder.rb