mqueue

2015-07-25 10:47:06 +08:00 · 2015-07-25 10:47:06 +08:00 · 268fcace65
parent c65d047fda
commit 268fcace65
1 changed files with 2 additions and 2 deletions
--- a/src/emqttd_bridge.erl
+++ b/src/emqttd_bridge.erl
@ -44,10 +44,10 @@
 -define(PING_DOWN_INTERVAL, 1000).

 -record(state, {node, subtopic,
-                qos,
+                qos                = ?QOS_2,
                topic_suffix       = <<>>,
                topic_prefix       = <<>>,
-                mqueue             = emqttd_mqueue:mqueue(),
+                mqueue             :: emqttd_mqueue:mqueue(),
                max_queue_len      = 0,
                ping_down_interval = ?PING_DOWN_INTERVAL,
                status             = up}).