Module: RisingDragon::SQS::Worker::ClassMethods

Defined in:
lib/rising_dragon/sqs/worker.rb

Instance Method Summary collapse

Instance Method Details

#emitter ⇒ Object 



27
28
29
 
# File 'lib/rising_dragon/sqs/worker.rb', line 27

def emitter
  @emitter ||= ::RisingDragon::SQS::Emitter.new
end

#rising_dragon_ignore(event_name) ⇒ Object 



23
24
25
 
# File 'lib/rising_dragon/sqs/worker.rb', line 23

def rising_dragon_ignore(event_name)
  emitter.ignore(event_name)
end

#rising_dragon_options(sqs_queue_name, weight, group, opt = {}) ⇒ Object 



12
13
14
15
16
17
 
# File 'lib/rising_dragon/sqs/worker.rb', line 12

def rising_dragon_options(sqs_queue_name, weight, group, opt = {})
  shoryuken_opt = { queue: sqs_queue_name, body_parser: :json }.merge(opt)
  shoryuken_options(shoryuken_opt)

  Shoryuken.add_queue(sqs_queue_name, weight, group)
end

#rising_dragon_register(event_name, handle_class) ⇒ Object 



19
20
21
 
# File 'lib/rising_dragon/sqs/worker.rb', line 19

def rising_dragon_register(event_name, handle_class)
  emitter.register(event_name, handle_class)
end