fix client

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

TODO

@@ -1 +1,2 @@
 1. Topic Trie
+2. MQTT frame parse

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) ->