Class: Queuel::Base::Message

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Defined in:
lib/queuel/base/message.rb

Direct Known Subclasses

IronMq::Message, Null::Message, SQS::Message

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(message_object = nil, options = {}) ⇒ Message

Returns a new instance of Message.



24
25
26
27
 
# File 'lib/queuel/base/message.rb', line 24

def initialize(message_object = nil, options = {})
  self.message_object = message_object
  self.options = options
end

Instance Attribute Details

#body ⇒ Object 



33
34
35
 
# File 'lib/queuel/base/message.rb', line 33

def body
  @body || decoded_raw_body
end

#id ⇒ Object

Returns the value of attribute id.



17
18
19
 
# File 'lib/queuel/base/message.rb', line 17

def id
  @id
end

#queue ⇒ Object

Returns the value of attribute queue.



20
21
22
 
# File 'lib/queuel/base/message.rb', line 20

def queue
  @queue
end

#raw_body ⇒ Object

Returns the value of attribute raw_body.



19
20
21
 
# File 'lib/queuel/base/message.rb', line 19

def raw_body
  @raw_body
end

Instance Method Details

#delete ⇒ Object

Raises:

  • (NotImplementedError) 


29
30
31
 
# File 'lib/queuel/base/message.rb', line 29

def delete
  raise NotImplementedError, "must define method #delete"
end

#empty? ⇒ Boolean Also known as: blank?

Returns:

  • (Boolean) 


37
38
39
 
# File 'lib/queuel/base/message.rb', line 37

def empty?
  raw_body.to_s.empty?
end

#present? ⇒ Boolean

Returns:

  • (Boolean) 


42
43
44
 
# File 'lib/queuel/base/message.rb', line 42

def present?
  !empty?
end