Class: Cloudist::Worker

Inherits:
Object show all
Defined in:
lib/cloudist/worker.rb

Direct Known Subclasses

GenericWorker

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(job, queue) ⇒ Worker

Returns a new instance of Worker.



6
7
8
9
10
11
 
# File 'lib/cloudist/worker.rb', line 6

def initialize(job, queue)
  @job, @queue, @payload = job, queue, job.payload

  # Do custom initialization
  self.setup if self.respond_to?(:setup)
end

Instance Attribute Details

#job ⇒ Object (readonly)

Returns the value of attribute job.



4
5
6
 
# File 'lib/cloudist/worker.rb', line 4

def job
  @job
end

#payload ⇒ Object (readonly)

Returns the value of attribute payload.



4
5
6
 
# File 'lib/cloudist/worker.rb', line 4

def payload
  @payload
end

#queue ⇒ Object (readonly)

Returns the value of attribute queue.



4
5
6
 
# File 'lib/cloudist/worker.rb', line 4

def queue
  @queue
end

Instance Method Details

#data ⇒ Object 



13
14
15
 
# File 'lib/cloudist/worker.rb', line 13

def data
  job.data
end

#headers ⇒ Object 



17
18
19
 
# File 'lib/cloudist/worker.rb', line 17

def headers
  job.headers
end

#id ⇒ Object 



21
22
23
 
# File 'lib/cloudist/worker.rb', line 21

def id
  job.id
end

#log ⇒ Object 



29
30
31
 
# File 'lib/cloudist/worker.rb', line 29

def log
  Cloudist.log
end

#process ⇒ Object

Raises:

  • (NotImplementedError) 


25
26
27
 
# File 'lib/cloudist/worker.rb', line 25

def process
  raise NotImplementedError, "Your worker class must subclass this method"
end