Method: Beetle::Message#set_delay!
- Defined in:
- lib/beetle/message.rb
#set_delay! ⇒ Object
store delay value in the deduplication store
197 198 199 |
# File 'lib/beetle/message.rb', line 197 def set_delay! @store.set(msg_id, :delay, now + next_delay(attempts)) end |