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