Sha256: 33ecc3842612050fa84d21de09064fa5f94f94de035c3582065b777d3ca95016
Contents?: true
Size: 455 Bytes
Versions: 15
Compression:
Stored size: 455 Bytes
Contents
# frozen_string_literal: true require "securerandom" require "kiev/request_id" require "kiev/shoryuken/context_reader" module Kiev module Shoryuken module Middleware class RequestId include Kiev::RequestId::Mixin def call(_worker, _queue, message, _body, &block) context_reader = Kiev::Shoryuken::ContextReader.new(message) wrap_request_id(context_reader, &block) end end end end end
Version data entries
15 entries across 15 versions & 1 rubygems