Sha256: 7d40635bf2ef622d8480bcc2c0bae80e43464eef1235444e8fd8340e49bff92a
Contents?: true
Size: 792 Bytes
Versions: 29
Compression:
Stored size: 792 Bytes
Contents
# frozen_string_literal: true module Karafka module ActiveJob # Contract for validating the options that can be altered with `#karafka_options` per job class # @note We keep this in the `Karafka::ActiveJob` namespace instead of `Karafka::Contracts` as # we want to keep ActiveJob related Karafka components outside of the core Karafka code and # all in the same place class JobOptionsContract < Contracts::Base configure do |config| config.error_messages = YAML.safe_load( File.read( File.join(Karafka.gem_root, 'config', 'errors.yml') ) ).fetch('en').fetch('validations').fetch('job_options') end optional(:dispatch_method) { |val| %i[produce_async produce_sync].include?(val) } end end end
Version data entries
29 entries across 29 versions & 1 rubygems