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