Module: Async::Background::Queue

Defined in:
lib/async/background/queue/store.rb,
lib/async/background/queue/client.rb,
lib/async/background/queue/notifier.rb,
lib/async/background/queue/socket_waker.rb,
lib/async/background/queue/socket_notifier.rb

Defined Under Namespace

Classes: Client, Notifier, SocketNotifier, SocketWaker, Store

Constant Summary collapse

EMPTY_OPTIONS = 
{}.freeze

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.default_client ⇒ Object

Returns the value of attribute default_client.



36
37
38
 
# File 'lib/async/background/queue/client.rb', line 36

def default_client
  @default_client
end

Class Method Details

.enqueue(job_class, *args, options: {}) ⇒ Object 



38
39
40
41
42
 
# File 'lib/async/background/queue/client.rb', line 38

def enqueue(job_class, *args, options: {})
  ensure_configured!
  merged = build_options(job_class, options)
  default_client.push(resolve_class_name(job_class), args, nil, options: merged)
end

.enqueue_at(time, job_class, *args, options: {}) ⇒ Object 



50
51
52
53
54
 
# File 'lib/async/background/queue/client.rb', line 50

def enqueue_at(time, job_class, *args, options: {})
  ensure_configured!
  merged = build_options(job_class, options)
  default_client.push_at(time, resolve_class_name(job_class), args, options: merged)
end

.enqueue_in(delay, job_class, *args, options: {}) ⇒ Object 



44
45
46
47
48
 
# File 'lib/async/background/queue/client.rb', line 44

def enqueue_in(delay, job_class, *args, options: {})
  ensure_configured!
  merged = build_options(job_class, options)
  default_client.push_in(delay, resolve_class_name(job_class), args, options: merged)
end