Przeglądaj źródła

Merge pull request #681 from farhadi/master

Fixing issues in cluster mode.
Feng Lee 9 lat temu
rodzic
commit
ce31194391
2 zmienionych plików z 2 dodań i 2 usunięć
  1. 1 1
      src/emqttd_pubsub.erl
  2. 1 1
      src/emqttd_router.erl

+ 1 - 1
src/emqttd_pubsub.erl

@@ -26,7 +26,7 @@
 -export([start_link/3, subscribe/2, unsubscribe/2, publish/2,
 -export([start_link/3, subscribe/2, unsubscribe/2, publish/2,
          async_subscribe/2, async_unsubscribe/2]).
          async_subscribe/2, async_unsubscribe/2]).
 
 
--export([subscribers/1]).
+-export([subscribers/1, dispatch/2]).
 
 
 %% gen_server.
 %% gen_server.
 -export([init/1, handle_call/3, handle_cast/2, handle_info/2,
 -export([init/1, handle_call/3, handle_cast/2, handle_info/2,

+ 1 - 1
src/emqttd_router.erl

@@ -64,7 +64,7 @@ mnesia(boot) ->
                 {attributes, record_info(fields, mqtt_route)}]);
                 {attributes, record_info(fields, mqtt_route)}]);
 
 
 mnesia(copy) ->
 mnesia(copy) ->
-    ok = emqttd_mnesia:copy_table(topic),
+    ok = emqttd_mnesia:copy_table(mqtt_topic),
     ok = emqttd_mnesia:copy_table(mqtt_route, ram_copies).
     ok = emqttd_mnesia:copy_table(mqtt_route, ram_copies).
 
 
 %%--------------------------------------------------------------------
 %%--------------------------------------------------------------------