spring2maz
f70d16e387
Add a test case to cover timeout message flush in emqx_misc
2018-09-21 18:58:18 +02:00
spring2maz
6fca651a84
Add connection/session shutdown policy
...
The hibernation behaviour is also changed (implicitly) in this commit:
Prior to this change, connection/session always hibernates after
the stats timer expires regardless of messages in mailbox.
After this commit, connection/session process only goes to hibernate
when the timer expires AND there is nothing left in the mailbox to
process
2018-09-21 18:58:18 +02:00
spring2maz
721f237bc4
Rewrite emqx_gc.erl
...
The implementation prior to this commit supports
only one gc enforcement policy which is message count threshold.
The new implementation introduces 1 more: volume threshold based
2018-09-21 22:56:34 +08:00
turtleDeng
98758752d4
Merge pull request #1839 from tigercl/emqx30
...
Calculate the 1.5 keep alive time exactly
2018-09-21 20:05:10 +08:00
terry-xiaoyu
389b3c80bc
Fix the message delivery to remote
2018-09-21 20:00:43 +08:00
周子博
ab2697671a
Change the location of the recording last packet timestamp
2018-09-21 19:59:32 +08:00
周子博
aade94711c
Use process dictionaries to record last packet timestamp
2018-09-21 18:50:26 +08:00
周子博
768d1786c7
Fix bug
2018-09-20 15:55:36 +08:00
周子博
073bf481c9
Calculate the 1.5 keep alive time exactly
2018-09-20 15:51:28 +08:00
HuangDan
3822ff987b
Fix function args
...
Add test cases for emqx_pool module
2018-09-18 09:15:46 +08:00
Feng Lee
ec061f7a21
Merge branch 'emqx30' of github.com:emqx/emqx into emqx30
2018-09-16 20:50:35 +08:00
Feng Lee
69e5869fa0
Add submit/2, async_submit/2 functions for emqx_pool module.
2018-09-16 20:49:47 +08:00
周子博
5eb92e37cc
Remove check for MQTT path, and normalize code
2018-09-14 11:49:17 +08:00
周子博
5465b015be
Add test case for last change
2018-09-14 11:49:17 +08:00
周子博
6f536eaac4
Add customized mqtt path for websocket
2018-09-14 11:49:17 +08:00
周子博
0c6a268539
Set default value of message expiry interval for not mqtt 5.0 message
2018-09-14 11:49:17 +08:00
周子博
88b3460715
Add feature for issue#1809
2018-09-14 11:49:17 +08:00
Gilbert Wong
45b2686e1c
Delete unnecessary code
...
Prior to this change, there are multiple deprecated functions.
2018-09-14 09:45:34 +08:00
HuangDan
fde6a2a4c3
Fixed issue #1811
...
Add tests case for issue #1811
2018-09-13 22:55:15 +08:00
spring2maz
8db9f3e81d
Update & clarify module doc for emqx_mqueue.erl
2018-09-13 09:08:07 +08:00
spring2maz
0c39a7620e
Rebar3 and erlang.mk dual support. ( #1806 )
...
* Rebar3 and erlang.mk dual support.
There was only erlang.mk support prior to this change.
The main reasons for this dual support are:
* Cover report upload can only be done by rebar3 in travis.ci
* We want to prepare for the future to build emqx releases using rebar3
* We do not want to stop supporting erlang.mk in one single step
* Add depencency version consistency check between erlang.mk and rebar.config
2018-09-09 21:51:42 +08:00
周子博
3caa41f751
Add run hook when duplicated subscription
2018-09-08 19:01:03 +08:00
周子博
23c91c0a40
no message
2018-09-08 18:31:44 +08:00
周子博
40977e529a
Retain flag in retained message must set to 1
2018-09-08 18:31:44 +08:00
Gilbert Wong
78020de302
fix pattern match bu
...
Prior to this change, when packet have topic alias, the check_pub_caps
function could not be matched correctly
This change fix this bug.
2018-09-08 12:50:14 +08:00
Gilbert Wong
2d10d6971d
add pattern match for topic alias
...
Prior to this change, it assume that topic_alias exists defaultly
which may cause the unexpected bug
This change fix this bug above
2018-09-08 12:01:22 +08:00
terry-xiaoyu
2121da3755
Ignore Will-Delay-Interval = 0
2018-09-08 10:10:22 +08:00
turtleDeng
0ec461484e
Merge pull request #1790 from emqx/emqx30-feng
...
Improve the Hooks' design
2018-09-07 21:46:30 +08:00
turtleDeng
66e9f9b02a
Merge pull request #1789 from Gilbert-Wong/emqx30
...
Check topic alias
2018-09-07 21:44:20 +08:00
turtleDeng
5ca61dd45c
Merge pull request #1788 from tigercl/emqx30
...
Support retain as published in subscription options
2018-09-07 21:43:56 +08:00
Gilbert
84e43c587d
Merge branch 'emqx30' into emqx30
2018-09-07 18:49:11 +08:00
周子博
6f6e24592b
Fix the reverse match
2018-09-07 18:32:03 +08:00
turtleDeng
ba176f2073
Merge pull request #1797 from terry-xiaoyu/banned_api_v2
...
Update for banned API
2018-09-07 17:50:30 +08:00
周子博
1326e89593
Fix a bug in emqx_protocol.erl
2018-09-07 15:16:32 +08:00
terry-xiaoyu
dd8513ad35
Update for banned API
...
Use `mnesia:foldl` to traverse mnesia rather than `mnesia:first` and
`mnesia:next`, as a badarg exception would occur if the record was
deleted while travering the whole table.
2018-09-07 14:10:16 +08:00
周子博
f8471afb97
Add handling of retain handling subscription option
2018-09-07 13:50:12 +08:00
Feng Lee
304a24ca6a
Code Review: Update the zone module
...
1. Add force_reload/0 management API
2. Change the reload interval to 5 minutes
2018-09-07 10:26:14 +08:00
Feng Lee
d9ad29476a
Code Review: Update the zone module
...
1. Add force_reload/1 API
2. Change the default reload interval to 5 minutes
2018-09-07 10:23:43 +08:00
周子博
d819ec0b58
Comment unused function in emqx_frame.erl
2018-09-07 10:18:21 +08:00
Gilbert Wong
765ab5ad7b
Add condition to handle when mqx_topic_alias do not exist
2018-09-06 19:09:29 +08:00
Feng Lee
328d035dab
Replace 'state' record with map
2018-09-06 18:43:47 +08:00
周子博
f95c82e37a
Add metric for DISCONNECT packet
2018-09-06 18:14:14 +08:00
Feng Lee
edf654727c
Rename emqx_mqtt_properties module to emqx_mqtt_props
2018-09-06 18:09:22 +08:00
Feng Lee
d99d0a22d0
Rename 'ignore' to 'ignored'
2018-09-06 17:54:32 +08:00
周子博
917eb8e29f
Make DISCONNECT packet with reason code 0x00 when this packet doesn't have payload
2018-09-06 17:17:09 +08:00
Feng Lee
2a75105580
Improve the Hooks's design
2018-09-06 16:27:16 +08:00
Gilbert Wong
c145cb89f4
add validate_properties for PUBLISH and fix error for SUB
2018-09-06 15:45:18 +08:00
周子博
42b3c9b4d6
Send DISCONNECT packet with reason code PROTOCOL_ERROR when topic is empty, add checks for topics
2018-09-06 14:47:34 +08:00
Gilbert Wong
9189d4ff41
catch topic_alias_invalid reasoncode
2018-09-06 14:24:07 +08:00
Gilbert Wong
876a983e93
Pub Packet delivered from client to server cannot contain sub id
2018-09-06 13:37:26 +08:00
