module ManageIQ::Messaging::Common

Private Instance Methods

auto_ack?(options) click to toggle source
# File lib/manageiq/messaging/common.rb, line 39
def auto_ack?(options)
  options.key?(:auto_ack) ? options[:auto_ack] : true
end
decode_body(headers, raw_body) click to toggle source
# File lib/manageiq/messaging/common.rb, line 19
def decode_body(headers, raw_body)
  return raw_body unless headers.kind_of?(Hash)
  case headers["encoding"] || headers[:encoding]
  when "json"
    JSON.parse(raw_body)
  when "yaml"
    YAML.safe_load(raw_body)
  else
    raw_body
  end
rescue => e # JSON or YAML parsing error
  logger.error("Error decoding message body: #{e.message}")
  logger.error(e.backtrace.join("\n"))
  raw_body
end
encode_body(headers, body) click to toggle source
# File lib/manageiq/messaging/common.rb, line 6
def encode_body(headers, body)
  return body if body.kind_of?(String)
  headers[:encoding] = encoding
  case encoding
  when "json"
    JSON.generate(body)
  when "yaml"
    body.to_yaml
  else
    raise "unknown message encoding: #{encoding}"
  end
end
payload_log(payload) click to toggle source
# File lib/manageiq/messaging/common.rb, line 35
def payload_log(payload)
  payload.to_s[0..100]
end