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.



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

def default_client
  @default_client
end

Class Method Details

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



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

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

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



47
48
49
50
 
# File 'lib/async/background/queue/client.rb', line 47

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

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



42
43
44
45
 
# File 'lib/async/background/queue/client.rb', line 42

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