Class: AdvancedSneakersActiveJob::Handler

Inherits:
Sneakers::Handlers::Oneshot
  • Object
show all
Defined in:
lib/advanced_sneakers_activejob/handler.rb

Overview

Handler puts error details to message header and reenqueues job with delay

Instance Method Summary collapse

Instance Method Details

#error(delivery_info, properties, message, error) ⇒ Object 



6
7
8
9
10
11
12
13
14
 
# File 'lib/advanced_sneakers_activejob/handler.rb', line 6

def error(delivery_info, properties, message, error)
  params = properties.to_h
  params[:headers] = patch_headers(params[:headers] || {}, delivery_info, error)
  params[:routing_key] = delivery_info.routing_key

  AdvancedSneakersActiveJob.delayed_publisher.publish(message, params)

  acknowledge(delivery_info, properties, message)
end