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