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