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