Class: PhobosDBCheckpoint::RetryFailure

Inherits:
Object
  • Object
show all
Includes:
Handler
Defined in:
lib/phobos_db_checkpoint/actions/retry_failure.rb

Instance Method Summary collapse

Methods included from Handler

#ack, included

Constructor Details

#initialize(failure) ⇒ RetryFailure

Returns a new instance of RetryFailure.



5
6
7
8
 
# File 'lib/phobos_db_checkpoint/actions/retry_failure.rb', line 5

def initialize(failure)
  @failure = failure
  @action_taken = nil
end

Instance Method Details

#perform ⇒ Object 



10
11
12
13
14
15
16
17
18
19
 
# File 'lib/phobos_db_checkpoint/actions/retry_failure.rb', line 10

def perform
  self
    .class
    .around_consume(payload, metadata) do
      @action_taken = handler.consume(payload, metadata)
    end

  @failure.destroy
  @action_taken
end