Module: Message

Defined in:
lib/message.rb,
lib/message/q.rb,
lib/message/job.rb,
lib/message/worker.rb,
lib/message/filters.rb,
lib/message/in_memory_queue.rb,
lib/message/filters/benchmarking.rb,
lib/message/filters/error_handling.rb,
lib/message/filters/retry_on_error.rb

Defined Under Namespace

Modules: Q Classes: AdapterNotFoundError, Filters, InMemoryQueue, Job, Worker

Class Method Summary collapse

Class Method Details

.job(name = nil, &block) ⇒ Object 



16
17
18
19
20
21
22
 
# File 'lib/message.rb', line 16

def job(name=nil, &block)
  if name
    Job.new(queue(name), &block)
  else
    Job
  end
end

.log(level, &block) ⇒ Object 



32
33
34
 
# File 'lib/message.rb', line 32

def log(level, &block)
  Message.logger.send(level) { "[Thread-#{Thread.current.object_id}] #{block.call}" }
end

.logger ⇒ Object 



36
37
38
 
# File 'lib/message.rb', line 36

def logger
  @logger ||= Logger.new(STDOUT)
end

.logger=(logger) ⇒ Object 



40
41
42
 
# File 'lib/message.rb', line 40

def logger=(logger)
  @logger = logger
end

.queue(name = nil) ⇒ Object 



8
9
10
11
12
13
14
 
# File 'lib/message.rb', line 8

def queue(name=nil)
  if name
    Q.init(name)
  else
    Q
  end
end

.reset ⇒ Object 



44
45
46
47
48
 
# File 'lib/message.rb', line 44

def reset
  Message.queue.reset
  Message.job.reset
  Message.worker.reset
end

.worker(job = nil) ⇒ Object 



24
25
26
27
28
29
30
 
# File 'lib/message.rb', line 24

def worker(job=nil)
  if job
    Worker.new(job)
  else
    Worker
  end
end