class Hoze::Message
Attributes
metadata[R]
payload[R]
source[R]
source_message[R]
timestamp[R]
Public Instance Methods
ack!()
click to toggle source
Acknowledge the message
# File lib/hoze/interface/message.rb, line 13 def ack! raise NotImplementedError.new("This message implementation doesn't support ack! method.") end
delay!(seconds)
click to toggle source
Ask for more time before acknowledging
# File lib/hoze/interface/message.rb, line 8 def delay! seconds raise NotImplementedError.new("This message implementation doesn't support delay! method.") end
reject!()
click to toggle source
Release the message
# File lib/hoze/interface/message.rb, line 18 def reject! raise NotImplementedError.new("This message implementation doesn't support reject! method.") end
retry!()
click to toggle source
Retry the message
# File lib/hoze/interface/message.rb, line 23 def retry! raise NotImplementedError.new("This message implementation doesn't support retry! method.") end