Class: Aws::Broker::Subscriber

Inherits:
Base
  • Object
show all
Defined in:
lib/aws/broker/subscriber.rb

Instance Method Summary collapse

Constructor Details

#initialize(topic, queue = nil) ⇒ Subscriber

Returns a new instance of Subscriber.



7
8
9
10
 
# File 'lib/aws/broker/subscriber.rb', line 7

def initialize(topic, queue=nil)
  @topic = topic
  @queue = queue || queue_name
end

Instance Method Details

#subscribe ⇒ Object 



12
13
14
15
16
17
18
19
20
21
22
23
 
# File 'lib/aws/broker/subscriber.rb', line 12

def subscribe
  return unless enabled?
  create_queue
  find_queue_arn
  create_topic
  sns.subscribe(
    topic_arn: @topic_arn,
    protocol:  'sqs',
    endpoint:  @queue_arn
  )
  set_queue_policy
end