zenmq

apps/zenmq/README

@@ -1,6 +1,6 @@
 ## Overview
 
-ZenMQ is a general architecture of a distributed messaging queue written in Erlang.
+ZenMQ is the core architecture of distributed pubsub messaging queue written in Erlang.
 
 ## Responsibilties
 

apps/zenmq/src/zenmq_router.erl

@@ -0,0 +1,4 @@
+
+-module(zenmq_router).
+
+

rel/files/emqttd.config

@@ -90,15 +90,15 @@
             %% Expired after 2 days
             {expired_after, 48},
             %% Max number of QoS 1 and 2 messages that can be “in flight” at one time.
-            {max_inflight_messages, 20},
+            {max_inflight_messages, 40},
             %% Max retries for unacknolege Qos1/2 messages
             {max_unack_retries, 3},
-            %% Retry after 2, 4,8 seconds
-            {unack_retry_after, 2}
+            %% Retry after 4, 8, 16 seconds
+            {unack_retry_after, 4}
         ]},
         {queue, [
             %% Max messages queued when client is disconnected, or inflight messsages is overload
-            {max_queued_messages, 100},
+            {max_queued_messages, 200},
             %% High watermark of queued messsages
             {high_queue_watermark, 0.6},
             %% Low watermark of queued messsages