Class: Eventboss::Queue

Inherits:
Object
  • Object
show all
Includes:
Comparable
Defined in:
lib/eventboss/queue.rb

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(name, configuration = Eventboss.configuration) ⇒ Queue

Returns a new instance of Queue.



17
18
19
20
 
# File 'lib/eventboss/queue.rb', line 17

def initialize(name, configuration = Eventboss.configuration)
  @client = configuration.sqs_client
  @name = name
end

Instance Attribute Details

#name ⇒ Object (readonly)

Returns the value of attribute name.



4
5
6
 
# File 'lib/eventboss/queue.rb', line 4

def name
  @name
end

Class Method Details

.build_name(source:, destination:, event:, env:, generic:) ⇒ Object 



6
7
8
9
10
11
12
13
14
15
 
# File 'lib/eventboss/queue.rb', line 6

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

Instance Method Details

#<=>(another_queue) ⇒ Object 



26
27
28
 
# File 'lib/eventboss/queue.rb', line 26

def <=>(another_queue)
  name <=> another_queue&.name
end

#eql?(another_queue) ⇒ Boolean

Returns:

  • (Boolean) 


30
31
32
 
# File 'lib/eventboss/queue.rb', line 30

def eql?(another_queue)
  name == another_queue&.name
end

#hash ⇒ Object 



34
35
36
 
# File 'lib/eventboss/queue.rb', line 34

def hash
  name.hash
end

#url ⇒ Object 



22
23
24
 
# File 'lib/eventboss/queue.rb', line 22

def url
  @url ||= client.get_queue_url(queue_name: name).queue_url
end