From cc67e10e6943f4d3eecb92d10644bc4dff756368 Mon Sep 17 00:00:00 2001 From: erylee Date: Thu, 20 Dec 2012 16:44:57 +0800 Subject: [PATCH] fix client --- Makefile | 2 +- TODO | 1 + src/emqtt_client.erl | 1 + 3 files changed, 3 insertions(+), 1 deletion(-) 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) ->