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}"
      begin
        response = @sns.publish topic_arn: @topic_arn, message: message
        @logger.info "        SNS response message id: #{response.message_id}"
      rescue Aws::SNS::Errors::ServiceError => e
        @logger.info "AWS SNS Encountered the error: #{e.inspect}"
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
fk-redis-sqspoller-0.1.2.5.8	lib/sqspoller/sns_forwarder.rb
fk-redis-sqspoller-0.1.2.5.7	lib/sqspoller/sns_forwarder.rb
fk-redis-sqspoller-0.1.2.5.6	lib/sqspoller/sns_forwarder.rb
fk-redis-sqspoller-0.1.2.5.6.alpha	lib/sqspoller/sns_forwarder.rb
fk-redis-sqspoller-0.1.2.5.5.alpha	lib/sqspoller/sns_forwarder.rb