Format code

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.

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),