diff --git a/Makefile b/Makefile index 1dc31e2b7..1b8b44d39 100644 --- a/Makefile +++ b/Makefile @@ -1,7 +1,7 @@ all: compile run: compile - erl -pa ebin -config etc/emqtt.config -s emqtt_app start + erl -pa ebin -pa lib/rabbitlib/ebin -config etc/emqtt.config -s emqtt_app start compile: deps rebar compile diff --git a/TODO b/TODO index 851d9ac39..9b74fc1b7 100644 --- a/TODO +++ b/TODO @@ -1 +1,2 @@ 1. Topic Trie +2. MQTT frame parse diff --git a/src/emqtt_client.erl b/src/emqtt_client.erl index 01ffe0897..9059173b0 100644 --- a/src/emqtt_client.erl +++ b/src/emqtt_client.erl @@ -24,6 +24,7 @@ init([]) -> handle_call({go, Sock}, _From, State) -> error_logger:info_msg("go.... sock: ~p", [Sock]), + inet:setopts(Sock, [{active, true}]), {reply, ok, State}. handle_cast(Msg, State) ->