
Untitled
By: a guest on
May 1st, 2012 | syntax:
None | size: 1.23 KB | hits: 15 | expires: Never
loop(Channel) ->
?INFO_MSG("YYYYYYYYYYYEEEEEEEEEE", []),
receive
{#'basic.deliver'{delivery_tag = Tag}, Content} ->
amqp_channel:cast(Channel, #'basic.ack'{delivery_tag = Tag}),
?INFO_MSG("HHHHHHHHHHHAAAAAAAAAA", []),
#amqp_msg{payload = Payload} = Content,
{Type, Data} = split_payload(Payload),
case Type of
[0, 0, 0, 200] ->
DecodedData = protocol_pb:decode_sitinresponse(list_to_binary(Data)),
{sitinresponse, Croupier, UserName, Amount, MoneyType, Status} = DecodedData,
?INFO_MSG(integer_to_list(Status), [])
%if
% Status == 0 ->
% gen_fsm:sync_send_event({global, Croupier}, {send_err_all, UserName, "set to this game"}),
% gen_fsm:sync_send_event({global, Croupier}, {sit_in, UserName, Amount});
% true ->
% ?INFO_MSG("YYYYYYYYYYYYYYYYYYYYYYYYY", []),
% gen_fsm:sync_send_event({global, Croupier}, {send_err, UserName, "You have no money"})
% end
end,
loop(Channel);
{ok, Type, Message} ->
Mess = <<Type/binary, Message/binary>>,
amqp_channel:cast(Channel, #'basic.publish'{ exchange = <<"">>, routing_key = <<"cashier">>}, #amqp_msg{payload = Mess}),
loop(Channel);
_ ->
loop(Channel)
end.