Sha256: b282c1d759680937c5d96a45ca56a3d3690b8ec7e2f55e893db83e4990e9d347
Contents?: true
Size: 702 Bytes
Versions: 31
Compression:
Stored size: 702 Bytes
Contents
module Shoryuken
class BodyParser
class << self
def parse(worker_class, sqs_msg)
body_parser = worker_class.get_shoryuken_options['body_parser']
case body_parser
when :json
JSON.parse(sqs_msg.body)
when Proc
body_parser.call(sqs_msg)
when :text, nil
sqs_msg.body
else
if body_parser.respond_to?(:parse)
# JSON.parse
body_parser.parse(sqs_msg.body)
elsif body_parser.respond_to?(:load)
# see https://github.com/phstc/shoryuken/pull/91
# JSON.load
body_parser.load(sqs_msg.body)
end
end
end
end
end
end
Version data entries
31 entries across 31 versions & 1 rubygems