Method: Beetle::Message#delayed?
- Defined in:
- lib/beetle/message.rb
#delayed?(t = nil) ⇒ Boolean
whether we should wait before running the handler
192 193 194 |
# File 'lib/beetle/message.rb', line 192 def delayed?(t = nil) (t ||= @store.get(msg_id, :delay)) && t.to_i > now end |