lib/chef/index_queue/consumer.rb in chef-0.9.14.beta.1 vs lib/chef/index_queue/consumer.rb in chef-0.9.14.rc.1
- old
+ new
@@ -54,10 +54,10 @@
end
end
alias :start :run
def call_action_for_message(message)
- amqp_payload = Chef::JSON.from_json(message[:payload], :create_additions => false, :max_nesting => false)
+ amqp_payload = Chef::JSONCompat.from_json(message[:payload], :create_additions => false, :max_nesting => false)
action = amqp_payload["action"].to_sym
app_payload = amqp_payload["payload"]
assert_method_whitelisted(action)
send(action, app_payload)
end