Class: TQ::Task

Inherits:
Struct
  • Object
show all
Defined in:
lib/tq/queue.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(*args) ⇒ Task

Returns a new instance of Task.



106
107
108
109
 
# File 'lib/tq/queue.rb', line 106

def initialize(*args)
  super
  @clock = Time
end

Instance Attribute Details

#expires ⇒ Object

Returns the value of attribute expires

Returns:

  • (Object) —

    the current value of expires



104
105
106
 
# File 'lib/tq/queue.rb', line 104

def expires
  @expires
end

#id ⇒ Object

Returns the value of attribute id

Returns:

  • (Object) —

    the current value of id



104
105
106
 
# File 'lib/tq/queue.rb', line 104

def id
  @id
end

#payload ⇒ Object

Returns the value of attribute payload

Returns:

  • (Object) —

    the current value of payload



104
105
106
 
# File 'lib/tq/queue.rb', line 104

def payload
  @payload
end

#queue ⇒ Object

Returns the value of attribute queue

Returns:

  • (Object) —

    the current value of queue



104
105
106
 
# File 'lib/tq/queue.rb', line 104

def queue
  @queue
end

#raw ⇒ Object

Returns the value of attribute raw

Returns:

  • (Object) —

    the current value of raw



104
105
106
 
# File 'lib/tq/queue.rb', line 104

def raw
  @raw
end

Instance Method Details

#clock!(_) ⇒ Object 



119
120
121
 
# File 'lib/tq/queue.rb', line 119

def clock!(_)
  @clock = _; return self
end

#extend!(secs = nil) ⇒ Object 



115
116
117
 
# File 'lib/tq/queue.rb', line 115

def extend!(secs=nil)
  self.queue.extend!(self, secs)
end

#finish! ⇒ Object 



111
112
113
 
# File 'lib/tq/queue.rb', line 111

def finish!
  self.queue.finish!(self)
end

#lease_expired? ⇒ Boolean

Returns:

  • (Boolean) 


131
132
133
 
# File 'lib/tq/queue.rb', line 131

def lease_expired?
  self.expires < @clock.now
end

#lease_remaining ⇒ Object 



127
128
129
 
# File 'lib/tq/queue.rb', line 127

def lease_remaining
  self.expires - @clock.now
end

#reset_clock! ⇒ Object 



123
124
125
 
# File 'lib/tq/queue.rb', line 123

def reset_clock!
  @clock = Time; return self
end