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