Class: FrenzyBunnies::Handlers::Oneshot

Inherits:
Object
  • Object
show all
Defined in:
lib/frenzy_bunnies/handlers/oneshot.rb

Instance Method Summary collapse

Constructor Details

#initialize(channel, queue, logger, opts) ⇒ Oneshot

Returns a new instance of Oneshot.



4
5
6
7
8
 
# File 'lib/frenzy_bunnies/handlers/oneshot.rb', line 4

def initialize(channel, queue, logger, opts)
  @channel = channel
  @opts    = opts
  @logger  = logger
end

Instance Method Details

#acknowledge(hdr, msg) ⇒ Object 



10
11
12
 
# File 'lib/frenzy_bunnies/handlers/oneshot.rb', line 10

def acknowledge(hdr, msg)
  @channel.acknowledge(hdr.delivery_tag, false)
end

#error(hdr, msg, err) ⇒ Object 



18
19
20
 
# File 'lib/frenzy_bunnies/handlers/oneshot.rb', line 18

def error(hdr, msg, err)
  reject(hdr, msg)
end

#noop(hdr, msg) ⇒ Object 



26
27
28
 
# File 'lib/frenzy_bunnies/handlers/oneshot.rb', line 26

def noop(hdr, msg)

end

#reject(hdr, msg, requeue = false) ⇒ Object 



14
15
16
 
# File 'lib/frenzy_bunnies/handlers/oneshot.rb', line 14

def reject(hdr, msg, requeue=false)
  @channel.reject(hdr.delivery_tag, requeue)
end

#timeout(hdr, msg) ⇒ Object 



22
23
24
 
# File 'lib/frenzy_bunnies/handlers/oneshot.rb', line 22

def timeout(hdr, msg)
  reject(hdr, msg)
end