fix
This commit is contained in:
parent
17532cb729
commit
6f8d936dfc
@ -53,6 +53,9 @@ loop(State=#state{socket = Socket, command = Command = #command{data = Data}}) -
|
|||||||
end.
|
end.
|
||||||
|
|
||||||
%% 处理请求命令
|
%% 处理请求命令
|
||||||
|
handle_command([<<"PING">>]) ->
|
||||||
|
{reply, encode({single_line, <<"PONG">>})};
|
||||||
|
|
||||||
handle_command(Args) ->
|
handle_command(Args) ->
|
||||||
logger:debug("[maxwell_redis_channel] args: ~p", [Args]),
|
logger:debug("[maxwell_redis_channel] args: ~p", [Args]),
|
||||||
{reply, encode({error, <<"Unsuported Command">>})}.
|
{reply, encode({error, <<"Unsuported Command">>})}.
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user