Sha256: b03b63520eb729310799f44cb0ac5a38b5c1aa3d5ba0949d87c9b97a6675784c
Contents?: true
Size: 794 Bytes
Versions: 13
Compression:
Stored size: 794 Bytes
Contents
module Eventboss class Queue include Comparable attr_reader :name def self.build_name(source:, destination:, event:, env:, generic:) source = if generic '' else "#{source}-" end "#{destination}-#{Eventboss.configuration.sns_sqs_name_infix}-#{source}#{event}-#{env}" end def initialize(name, configuration = Eventboss.configuration) @client = configuration.sqs_client @name = name end def url @url ||= client.get_queue_url(queue_name: name).queue_url end def <=>(another_queue) name <=> another_queue&.name end def eql?(another_queue) name == another_queue&.name end def hash name.hash end private attr_reader :client end end
Version data entries
13 entries across 13 versions & 1 rubygems