Method: Beetle::Message#decode

Defined in:
lib/beetle/message.rb

#decode ⇒ Object

extracts various values from the AMQP header properties



87
88
89
90
91
92
93
94
95
96
97
98
 
# File 'lib/beetle/message.rb', line 87

def decode #:nodoc:
  amqp_headers = header.attributes
  @uuid = amqp_headers[:message_id]
  @timestamp = amqp_headers[:timestamp]
  headers = amqp_headers[:headers].symbolize_keys
  @format_version = headers[:format_version].to_i
  @flags = headers[:flags].to_i
  @expires_at = headers[:expires_at].to_i
rescue Exception => @exception
  Beetle::reraise_expectation_errors!
  logger.error "Could not decode message. #{self.inspect}"
end