class Liebre::Actor::Consumer::Callback
Attributes
consumer[R]
info[R]
Public Class Methods
new(consumer, info)
click to toggle source
# File lib/liebre/actor/consumer/callback.rb, line 6 def initialize consumer, info @consumer = consumer @info = info end
Public Instance Methods
ack(opts = {})
click to toggle source
# File lib/liebre/actor/consumer/callback.rb, line 11 def ack opts = {} consumer.ack(info, opts) end
failed(error)
click to toggle source
# File lib/liebre/actor/consumer/callback.rb, line 23 def failed error consumer.failed(info, error) end
nack(opts = {})
click to toggle source
# File lib/liebre/actor/consumer/callback.rb, line 15 def nack opts = {} consumer.nack(info, opts) end
reject(opts = {})
click to toggle source
# File lib/liebre/actor/consumer/callback.rb, line 19 def reject opts = {} consumer.reject(info, opts) end