Sha256: 88c1bed787667321ebc6e71d70ec4fa4e3f33cb436e3b0419d732673bc629f69
Contents?: true
Size: 1.04 KB
Versions: 14
Compression:
Stored size: 1.04 KB
Contents
module ManageIQ
module Messaging
module Common
private
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
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
def payload_log(payload)
payload.to_s[0..100]
end
def auto_ack?(options)
options.key?(:auto_ack) ? options[:auto_ack] : true
end
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems