class MagicPipe::Senders::Async
Constants
- SETTINGS
Public Instance Methods
call()
click to toggle source
# File lib/magic_pipe/senders/async.rb, line 45 def call enqueue end
enqueue()
click to toggle source
# File lib/magic_pipe/senders/async.rb, line 49 def enqueue options = SETTINGS.merge({ "queue" => queue_name, "args" => [ decomposed_object, @topic, @time.to_i, @config.client_name ] }) Sidekiq::Client.push(options) end
Private Instance Methods
decomposed_object()
click to toggle source
# File lib/magic_pipe/senders/async.rb, line 70 def decomposed_object loader = MagicPipe::Loaders.lookup(@config.loader) loader.new(@object, @wrapper).decompose end
queue_name()
click to toggle source
# File lib/magic_pipe/senders/async.rb, line 66 def queue_name @config.async_transport_options[:queue] end