class Basquiat::Adapters::RabbitMq::BaseStrategy

Attributes

session[R]

Public Class Methods

new(session) click to toggle source
# File lib/basquiat/adapters/rabbitmq/requeue_strategies/base_strategy.rb, line 17
def initialize(session)
  @session = session
end
session_options() click to toggle source
# File lib/basquiat/adapters/rabbitmq/requeue_strategies/base_strategy.rb, line 8
def session_options
  {}
end
setup(options = {}) click to toggle source
# File lib/basquiat/adapters/rabbitmq/requeue_strategies/base_strategy.rb, line 12
def setup(options = {})
  @options = options
end

Public Instance Methods

ack(message) click to toggle source
# File lib/basquiat/adapters/rabbitmq/requeue_strategies/base_strategy.rb, line 25
def ack(message)
  @session.channel.ack(message.delivery_tag)
end
nack(message) click to toggle source
# File lib/basquiat/adapters/rabbitmq/requeue_strategies/base_strategy.rb, line 29
def nack(message)
  @session.channel.nack(message.delivery_tag, false)
end
requeue(message) click to toggle source
# File lib/basquiat/adapters/rabbitmq/requeue_strategies/base_strategy.rb, line 33
def requeue(message)
  @session.channel.nack(message.delivery_tag, false, true)
end
run(_message) click to toggle source
# File lib/basquiat/adapters/rabbitmq/requeue_strategies/base_strategy.rb, line 21
def run(_message)
  raise Basquiat::Errors::SubclassResponsibility
end