From 1e91c0e220b4ee84e4dc98a152963f24fe8cc882 Mon Sep 17 00:00:00 2001 From: Feng Date: Thu, 23 Feb 2017 23:01:20 +0800 Subject: [PATCH] Format code --- src/emqttd_bridge.erl | 4 ++-- src/emqttd_pubsub.erl | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/emqttd_bridge.erl b/src/emqttd_bridge.erl index 7b3015f6d..a1dd34bcc 100644 --- a/src/emqttd_bridge.erl +++ b/src/emqttd_bridge.erl @@ -79,8 +79,8 @@ init([Pool, Id, Node, Topic, Options]) -> MQueue = emqttd_mqueue:new(qname(Node, Topic), [{max_len, State#state.max_queue_len}], emqttd_alarm:alarm_fun()), - {ok, State#state{pool = Pool, id = Id, mqueue = MQueue}, hibernate, - {backoff, 1000, 1000, 10000}}; + {ok, State#state{pool = Pool, id = Id, mqueue = MQueue}, + hibernate, {backoff, 1000, 1000, 10000}}; false -> {stop, {cannot_connect_node, Node}} end. diff --git a/src/emqttd_pubsub.erl b/src/emqttd_pubsub.erl index 393e4b788..d976618cd 100644 --- a/src/emqttd_pubsub.erl +++ b/src/emqttd_pubsub.erl @@ -164,8 +164,8 @@ pick(Subscriber) -> init([Pool, Id, Env]) -> ?GPROC_POOL(join, Pool, Id), - {ok, #state{pool = Pool, id = Id, env = Env}, hibernate, - {backoff, 2000, 2000, 20000}}. + {ok, #state{pool = Pool, id = Id, env = Env}, + hibernate, {backoff, 2000, 2000, 20000}}. handle_call({subscribe, Topic, Subscriber, Options}, _From, State) -> add_subscriber(Topic, Subscriber, Options),