class PhobosDBCheckpoint::RetryFailure
Public Class Methods
new(failure)
click to toggle source
# File lib/phobos_db_checkpoint/actions/retry_failure.rb, line 7 def initialize(failure) @failure = failure @action_taken = nil end
Public Instance Methods
perform()
click to toggle source
# File lib/phobos_db_checkpoint/actions/retry_failure.rb, line 12 def perform around_consume(payload, metadata) do @action_taken = handler.consume(payload, metadata) end @failure.destroy @action_taken end
Private Instance Methods
handler()
click to toggle source
# File lib/phobos_db_checkpoint/actions/retry_failure.rb, line 31 def handler @failure .configured_handler .new end
metadata()
click to toggle source
# File lib/phobos_db_checkpoint/actions/retry_failure.rb, line 27 def metadata @failure.metadata.merge(retry_count: 0) end
payload()
click to toggle source
# File lib/phobos_db_checkpoint/actions/retry_failure.rb, line 23 def payload @failure.payload.to_json end