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