anchor.diff:                    EntitySpecificPayload) ->
       Msg = {[{<<"message_type">>, <<"action">>},
               {<<"message_version">>, ?CHEF_ACTIONS_MESSAGE_VERSION},
  -            {<<"organization_name">>, OrgName},
  +            {<<"organization_name">>, get_org_name(OrgName)},
               %% Request Level Info
               {<<"service_hostname">>, hostname()},
               {<<"recorded_at">>, req_header("x-ops-timestamp", Req)},
  
positive.code:             {<<"task">>, Task}
              | EntitySpecificPayload
             ]},
  
      Msg0 = maybe_add_remote_request_id(Msg, req_header("x-remote-request-id", Req)),
      Msg1 = maybe_add_data(Msg0, FullActionPayload),
      iolist_to_binary(chef_json:encode(Msg1)).
  
  maybe_add_remote_request_id(Msg, undefined) ->
    Msg;
  maybe_add_remote_request_id(Msg, RemoteRequestId) ->
    ej:set({<<"remote_request_id">>}, Msg, RemoteRequestId).
  
  -spec routing_key(EntityType :: <<_:32,_:_*8>>, Method :: <<_:48>>) -> binary().
  routing_key(EntityType, Method) ->
  
negative.code:                                     ]};
  extract_entity_info(Req, #user_state{user_data = FullActionPayload}) ->
      Name = req_or_data_name(chef_wm_util:object_name(user, Req), FullActionPayload),
      CorrectedName = get_corrected_name(Name, "username", FullActionPayload),
      {FullActionPayload, <<"user">>, [{<<"entity_type">>, <<"user">>},
                                       {<<"entity_name">>, CorrectedName}
                                      ]}.
  
  get_corrected_name(undefined, NameKey, FullActionPayload) ->
      ej:get({NameKey}, FullActionPayload);
  get_corrected_name(Name, _NameKey, _FullActionPayload) ->
      Name.
  
  -spec requestor_name(Requestor:: #chef_client{} | #chef_user{}) -> binary().
  requestor_name(#chef_client{name = Name}) ->
  