Class: Strum::Esb::ThreadVariablesCleaner

Inherits:

Object

Object
Strum::Esb::ThreadVariablesCleaner

show all

Defined in:: lib/strum/esb.rb

Instance Method Summary collapse

#call(deserialized_msg, delivery_info, metadata, handler) ⇒ Object
#initialize(app, *args) ⇒ ThreadVariablesCleaner constructor

A new instance of ThreadVariablesCleaner.

Constructor Details

#initialize(app, *args) ⇒ `ThreadVariablesCleaner`

Returns a new instance of ThreadVariablesCleaner.

# File 'lib/strum/esb.rb', line 64

def initialize(app, *args)
  @app = app
  @args = args
end

Instance Method Details

#call(deserialized_msg, delivery_info, metadata, handler) ⇒ `Object`

# File 'lib/strum/esb.rb', line 69

def call(deserialized_msg, delivery_info, metadata, handler)
  Thread.current.keys.each { |key| Thread.current[key] = nil }
  @app.call(deserialized_msg, delivery_info, metadata, handler)
end