Sha256: b7e56fa3307190a82558852e60e0c600d185a1bff9fbc55f1bde8027e38d3e5c

Contents?: true

Size: 808 Bytes

Versions: 4

Compression:

Stored size: 808 Bytes

Contents

require 'cloud_powers/aws_resources'
require 'cloud_powers/helpers'
require 'cloud_powers/resource'
require 'cloud_powers/synapse/queue'
require 'cloud_powers/zenv'

module Smash
  module CloudPowers
    module Synapse
      module Queue
        # The Queue::Resource class helps wrap up information and functionality of a Queue on SQS.
        # It is basically just an abstraction to make using SQS simpler
        class Poller < Smash::CloudPowers::Resource
          attr_accessor :sqs

          def initialize(name:, client: sqs, **config)
            super
            @sqs = client
            @call_name = queue_poller_name(name)
          end

          def create_resource
            @response = queue_poller(queue_url: address, client: sqs)
          end
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
cloud_powers-1.1.1 lib/cloud_powers/synapse/queue/poller.rb
cloud_powers-1.1.0 lib/cloud_powers/synapse/queue/poller.rb
cloud_powers-1.0.1 lib/cloud_powers/synapse/queue/poller.rb
cloud_powers-1.0.0 lib/cloud_powers/synapse/queue/poller.rb