Method: Beetle::Message#set_timeout!
- Defined in:
- lib/beetle/message.rb
#set_timeout! ⇒ Object
store handler timeout timestamp in the deduplication store
167 168 169 |
# File 'lib/beetle/message.rb', line 167 def set_timeout! @store.set(msg_id, :timeout, (now + timeout).ceil) end |