From 72d9ed2024fc89c2913bce48132bc7930737b110 Mon Sep 17 00:00:00 2001 From: Feng Date: Sat, 12 Mar 2016 00:30:37 +0800 Subject: [PATCH] emqttd:publish|subscribe --- src/emqttd_bridge.erl | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/emqttd_bridge.erl b/src/emqttd_bridge.erl index 32e1c02ee..0e24d1ed5 100644 --- a/src/emqttd_bridge.erl +++ b/src/emqttd_bridge.erl @@ -72,7 +72,7 @@ init([Node, Topic, Options]) -> MQueue = emqttd_mqueue:new(qname(Node, Topic), [{max_len, State#state.max_queue_len}], emqttd_alarm:alarm_fun()), - emqttd_pubsub:subscribe({Topic, State#state.qos}), + emqttd:subscribe(Topic), {ok, State#state{mqueue = MQueue}}; false -> {stop, {cannot_connect, Node}} @@ -108,7 +108,7 @@ handle_info({dispatch, _Topic, Msg}, State = #state{mqueue = MQ, status = down}) {noreply, State#state{mqueue = emqttd_mqueue:in(Msg, MQ)}}; handle_info({dispatch, _Topic, Msg}, State = #state{node = Node, status = up}) -> - rpc:cast(Node, emqttd_pubsub, publish, [transform(Msg, State)]), + rpc:cast(Node, emqttd, publish, [transform(Msg, State)]), {noreply, State, hibernate}; handle_info({nodedown, Node}, State = #state{node = Node, ping_down_interval = Interval}) ->