From 237e65a4e0e70df01f03367afa89f4f8c5139feb Mon Sep 17 00:00:00 2001 From: Feng Lee Date: Fri, 31 Aug 2018 10:22:16 +0800 Subject: [PATCH] Use emqx_mqueue:init/1 to create a mqueue --- src/emqx_local_bridge.erl | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/emqx_local_bridge.erl b/src/emqx_local_bridge.erl index 9ed8fdbac..66cdf4010 100644 --- a/src/emqx_local_bridge.erl +++ b/src/emqx_local_bridge.erl @@ -63,8 +63,9 @@ init([Pool, Id, Node, Topic, Options]) -> Share = iolist_to_binary(["$bridge:", atom_to_list(Node), ":", Topic]), emqx_broker:subscribe(Topic, self(), [{share, Share}, {qos, ?QOS_0}]), State = parse_opts(Options, #state{node = Node, subtopic = Topic}), - %%TODO: queue.... - MQueue = emqx_mqueue:new(qname(Node, Topic), [{max_len, State#state.max_queue_len}]), + MQueue = emqx_mqueue:init(#{type => simple, + max_len => State#state.max_queue_len, + store_qos0 => true}), {ok, State#state{pool = Pool, id = Id, mqueue = MQueue}}; false -> {stop, {cannot_connect_node, Node}}