Class: MagicPipe::Senders::Async

Inherits:
Base
  • Object
show all
Defined in:
lib/magic_pipe/senders/async.rb

Defined Under Namespace

Classes: Worker

Constant Summary collapse

SETTINGS = 
{
  "class" => Worker,
  "retry" => true
}

Instance Method Summary collapse

Methods inherited from Base

#initialize

Constructor Details

This class inherits a constructor from MagicPipe::Senders::Base

Instance Method Details

#call ⇒ Object 



45
46
47
 
# File 'lib/magic_pipe/senders/async.rb', line 45

def call
  enqueue
end

#enqueue ⇒ Object 



49
50
51
52
53
54
55
56
57
58
59
60
 
# 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