class Sidekiq::Extensions::Proxy
Public Class Methods
new(performable, target, options = {})
click to toggle source
# File lib/sidekiq/extensions/generic_proxy.rb, line 10 def initialize(performable, target, options = {}) @performable = performable @target = target @opts = options.transform_keys(&:to_s) end
Public Instance Methods
method_missing(name, *args)
click to toggle source
# File lib/sidekiq/extensions/generic_proxy.rb, line 16 def method_missing(name, *args) # Sidekiq has a limitation in that its message must be JSON. # JSON can't round trip real Ruby objects so we use YAML to # serialize the objects to a String. The YAML will be converted # to JSON and then deserialized on the other side back into a # Ruby object. obj = [@target, name, args] marshalled = ::YAML.dump(obj) if marshalled.size > SIZE_LIMIT ::Sidekiq.logger.warn { "#{@target}.#{name} job argument is #{marshalled.bytesize} bytes, you should refactor it to reduce the size" } end @performable.client_push({"class" => @performable, "args" => [marshalled], "display_class" => "#{@target}.#{name}"}.merge(@opts)) end