Class: Hoze::Message

Inherits:
Object
  • Object
show all
Defined in:
lib/hoze/interface/message.rb

Direct Known Subclasses

PubSubMessage

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#metadata ⇒ Object (readonly)

Returns the value of attribute metadata.



5
6
7
 
# File 'lib/hoze/interface/message.rb', line 5

def metadata
  @metadata
end

#payload ⇒ Object (readonly)

Returns the value of attribute payload.



5
6
7
 
# File 'lib/hoze/interface/message.rb', line 5

def payload
  @payload
end

#source ⇒ Object (readonly)

Returns the value of attribute source.



5
6
7
 
# File 'lib/hoze/interface/message.rb', line 5

def source
  @source
end

#source_message ⇒ Object (readonly)

Returns the value of attribute source_message.



5
6
7
 
# File 'lib/hoze/interface/message.rb', line 5

def source_message
  @source_message
end

#timestamp ⇒ Object (readonly)

Returns the value of attribute timestamp.



5
6
7
 
# File 'lib/hoze/interface/message.rb', line 5

def timestamp
  @timestamp
end

Instance Method Details

#ack! ⇒ Object

Acknowledge the message

Raises:

  • (NotImplementedError) 


13
14
15
 
# File 'lib/hoze/interface/message.rb', line 13

def ack!
  raise NotImplementedError.new("This message implementation doesn't support ack! method.")
end

#delay!(seconds) ⇒ Object

Ask for more time before acknowledging

Raises:

  • (NotImplementedError) 


8
9
10
 
# File 'lib/hoze/interface/message.rb', line 8

def delay! seconds
  raise NotImplementedError.new("This message implementation doesn't support delay! method.")
end

#reject! ⇒ Object

Release the message

Raises:

  • (NotImplementedError) 


18
19
20
 
# File 'lib/hoze/interface/message.rb', line 18

def reject!
  raise NotImplementedError.new("This message implementation doesn't support reject! method.")
end

#retry! ⇒ Object

Retry the message

Raises:

  • (NotImplementedError) 


23
24
25
 
# File 'lib/hoze/interface/message.rb', line 23

def retry!
  raise NotImplementedError.new("This message implementation doesn't support retry! method.")
end