Sha256: 125f0630dd253c4d2b399f896ec231718c779c19665dcfcdd4db7343d865a2cf
Contents?: true
Size: 1.25 KB
Versions: 15
Compression:
Stored size: 1.25 KB
Contents
# frozen_string_literal: true require_relative "base" module Kiev module Shoryuken require_relative "shoryuken/middleware" class << self def enable(base = nil) base ||= ::Shoryuken base.configure_client do |config| enable_client_middleware(config) end base.configure_server do |config| enable_client_middleware(config) enable_server_middleware(config) end end def enable_server_middleware(config) server_mw_enabled = false config.server_middleware do |chain| chain.add(Middleware::RequestStore) chain.add(Middleware::RequestId) chain.add(Middleware::StoreRequestDetails) chain.add(Middleware::RequestLogger) server_mw_enabled = true end server_mw_enabled # Shoryuken configuration may skip that block in non-worker setups end def enable_client_middleware(config) config.client_middleware do |chain| chain.add(Middleware::MessageTracer) end end def suffix_tree_path(config, tag) config.server_middleware do |chain| chain.insert_after(Middleware::RequestId, Middleware::TreePathSuffix, tag) end end end end end
Version data entries
15 entries across 15 versions & 1 rubygems