Fixing issues in cluster mode.
This commit is contained in:
parent
887a3a0578
commit
49258f4a0c
|
@ -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,
|
||||||
|
|
|
@ -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).
|
||||||
|
|
||||||
%%--------------------------------------------------------------------
|
%%--------------------------------------------------------------------
|
||||||
|
|
Loading…
Reference in New Issue