From f69b6270fbd4f157e244be467f595a6dcc97cf23 Mon Sep 17 00:00:00 2001 From: Feng Date: Thu, 11 Jun 2015 12:08:18 +0800 Subject: [PATCH] zenmq --- apps/zenmq/README | 2 +- apps/zenmq/src/zenmq_router.erl | 4 ++++ rel/files/emqttd.config | 8 ++++---- 3 files changed, 9 insertions(+), 5 deletions(-) create mode 100644 apps/zenmq/src/zenmq_router.erl diff --git a/apps/zenmq/README b/apps/zenmq/README index 5b60d8891..e91132732 100644 --- a/apps/zenmq/README +++ b/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 diff --git a/apps/zenmq/src/zenmq_router.erl b/apps/zenmq/src/zenmq_router.erl new file mode 100644 index 000000000..ecd6511e0 --- /dev/null +++ b/apps/zenmq/src/zenmq_router.erl @@ -0,0 +1,4 @@ + +-module(zenmq_router). + + diff --git a/rel/files/emqttd.config b/rel/files/emqttd.config index fc15fb0a2..ca11109e4 100644 --- a/rel/files/emqttd.config +++ b/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