Module: ActiveJob::Temporal::DeadLetterPayloadValidation

Extended by:
DeadLetterPayloadValidation
Included in:
DeadLetterPayloadValidation
Defined in:
lib/activejob/temporal/dead_letter_payload_validation.rb

Instance Method Summary collapse

Instance Method Details

#validate!(payload) ⇒ Object 



8
9
10
11
12
13
14
 
# File 'lib/activejob/temporal/dead_letter_payload_validation.rb', line 8

def validate!(payload)
  validate_metadata!(payload_value(payload, :dead_letter), "dead_letter.queue")

  Array(payload_value(payload, :chain)).each do |chain_step|
    validate_metadata!(payload_value(chain_step, :dead_letter), "chain.dead_letter.queue")
  end
end