class Kybus::Configuration::Autoconfigs::Aws::Sqs
Public Class Methods
from_config(config)
click to toggle source
# File lib/kybus/configs/autoconfigs/aws/sqs.rb, line 9 def self.from_config(config) require 'aws-sdk-sqs' new(config) end
new(config)
click to toggle source
# File lib/kybus/configs/autoconfigs/aws/sqs.rb, line 14 def initialize(config) @config = config @client = ::Aws::SQS::Client.new( symbolize(config).reject do |k, _| %i[queue test_connection].include? k end ) queue = @client.get_queue_url(queue_name: @config['queue']) @connection = ::Aws::SQS::Queue.new( url: queue[:queue_url], client: @client ) end
Public Instance Methods
raw()
click to toggle source
# File lib/kybus/configs/autoconfigs/aws/sqs.rb, line 28 def raw @connection end