Module: Bluth::Handler

Included in:
ExampleHandler
Defined in:
lib/bluth.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.extended(obj) ⇒ Object 



168
169
170
171
172
173
174
 
# File 'lib/bluth.rb', line 168

def self.extended(obj)
  obj.send :include, Familia
  obj.class_string :success
  obj.class_string :failure
  obj.class_string :running
  Bluth.handlers << obj
end

Instance Method Details

#all ⇒ Object 



200
201
202
203
204
 
# File 'lib/bluth.rb', line 200

def all
  Bluth::Gob.instances.select do |gob|
    gob.handler == self
  end
end

#enqueue(data = {}, q = nil) ⇒ Object 



182
183
184
185
186
187
188
189
190
191
192
 
# File 'lib/bluth.rb', line 182

def enqueue(data={},q=nil)
  q = self.queue(q)
  gob = Gob.create generate_id(data), self, data
  gob.current_queue = q.name
  gob.created
  gob.attempts = 0
  gob.save
  Familia.ld "ENQUEUING: #{self} #{gob.jobid.short} to #{q}"
  q << gob.jobid
  gob
end

#generate_id(*args) ⇒ Object 



197
198
199
 
# File 'lib/bluth.rb', line 197

def generate_id(*args)
  [self, Process.pid, Bluth.sysinfo.hostname, Time.now.to_f, *args].gibbler
end

#prepare ⇒ Object 



205
206
 
# File 'lib/bluth.rb', line 205

def prepare
end

#queue(name = nil) ⇒ Object 



193
194
195
196
 
# File 'lib/bluth.rb', line 193

def queue(name=nil)
  @queue = name if name
  Bluth::Queue.send(@queue || :high)
end