From 78b305ff85b508ed20c54637c9dc75c4f6842d5f Mon Sep 17 00:00:00 2001 From: Feng Date: Sun, 14 Aug 2016 20:26:52 +0800 Subject: [PATCH 1/3] mnesia -> ets --- src/emqttd_cli.erl | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/emqttd_cli.erl b/src/emqttd_cli.erl index 94c063c54..b4f05be27 100644 --- a/src/emqttd_cli.erl +++ b/src/emqttd_cli.erl @@ -224,7 +224,7 @@ subscriptions(["list"]) -> end, emqttd:subscriptions()); subscriptions(["show", ClientId]) -> - case mnesia:dirty_read(mqtt_subscription, bin(ClientId)) of + case ets:dirty_read(mqtt_subscription, bin(ClientId)) of [] -> ?PRINT_MSG("Not Found.~n"); Records -> print(Records) end; From f25420309c7c488a39c0a8eed991e42725949339 Mon Sep 17 00:00:00 2001 From: Feng Date: Tue, 16 Aug 2016 23:08:59 +0800 Subject: [PATCH 2/3] -type(). --- include/emqttd.hrl | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/include/emqttd.hrl b/include/emqttd.hrl index ccf4ef47d..0fc868355 100644 --- a/include/emqttd.hrl +++ b/include/emqttd.hrl @@ -40,7 +40,7 @@ %% PubSub %%-------------------------------------------------------------------- --type pubsub() :: publish | subscribe. +-type(pubsub() :: publish | subscribe). -define(PUBSUB(PS), (PS =:= publish orelse PS =:= subscribe)). From b59a1d7547d78aefa8d526e3107387deac77d3be Mon Sep 17 00:00:00 2001 From: Feng Date: Wed, 17 Aug 2016 08:49:45 +0800 Subject: [PATCH 3/3] sender --- src/emqttd_pubsub.erl | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/emqttd_pubsub.erl b/src/emqttd_pubsub.erl index 036b345aa..1af6274bf 100644 --- a/src/emqttd_pubsub.erl +++ b/src/emqttd_pubsub.erl @@ -69,7 +69,7 @@ route(Routes, Delivery) -> {ok, DelAcc1} = route([Route], DelAcc), DelAcc1 end, Delivery, Routes)}. -delivery(Msg) -> #mqtt_delivery{message = Msg, flows = []}. +delivery(Msg) -> #mqtt_delivery{sender = self(), message = Msg, flows = []}. %% @doc Forward message to another node... forward(Node, To, Delivery) ->