class SXS::Publishers::SQS

Public Class Methods

new(queue_url, resource: ::Aws::SQS::Resource) click to toggle source
# File lib/sxs/publishers/sqs.rb, line 8
def initialize(queue_url, resource: ::Aws::SQS::Resource)
  @queue_url = queue_url
  @resource  = resource
end

Public Instance Methods

publish(body) click to toggle source
# File lib/sxs/publishers/sqs.rb, line 13
def publish(body)
  queue.send_message message_body: body
end

Private Instance Methods

queue() click to toggle source
# File lib/sxs/publishers/sqs.rb, line 19
def queue
  @queue ||= @resource.new.queue(@queue_url)
end