f70d16e387
Add a test case to cover timeout message flush in emqx_misc
2018-09-21 18:58:18 +02:00
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
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
98758752d4
Merge pull request #1839 from tigercl/emqx30
...
Calculate the 1.5 keep alive time exactly
2018-09-21 20:05:10 +08:00
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
e940c1c970
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-19 21:08:16 +02:00
3822ff987b
Fix function args
...
Add test cases for emqx_pool module
2018-09-18 09:15:46 +08:00
ec061f7a21
Merge branch 'emqx30' of github.com:emqx/emqx into emqx30
2018-09-16 20:50:35 +08:00
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
45b2686e1c
Delete unnecessary code
...
Prior to this change, there are multiple deprecated functions.
2018-09-14 09:45:34 +08:00
fde6a2a4c3
Fixed issue #1811
...
Add tests case for issue #1811
2018-09-13 22:55:15 +08:00
8db9f3e81d
Update & clarify module doc for emqx_mqueue.erl
2018-09-13 09:08:07 +08:00
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
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
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
2121da3755
Ignore Will-Delay-Interval = 0
2018-09-08 10:10:22 +08:00
0ec461484e
Merge pull request #1790 from emqx/emqx30-feng
...
Improve the Hooks' design
2018-09-07 21:46:30 +08:00
66e9f9b02a
Merge pull request #1789 from Gilbert-Wong/emqx30
...
Check topic alias
2018-09-07 21:44:20 +08:00
5ca61dd45c
Merge pull request #1788 from tigercl/emqx30
...
Support retain as published in subscription options
2018-09-07 21:43:56 +08:00
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
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
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
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
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
765ab5ad7b
Add condition to handle when mqx_topic_alias do not exist
2018-09-06 19:09:29 +08:00
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
edf654727c
Rename emqx_mqtt_properties module to emqx_mqtt_props
2018-09-06 18:09:22 +08:00
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
2a75105580
Improve the Hooks's design
2018-09-06 16:27:16 +08:00
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
9189d4ff41
catch topic_alias_invalid reasoncode
2018-09-06 14:24:07 +08:00
876a983e93
Pub Packet delivered from client to server cannot contain sub id
2018-09-06 13:37:26 +08:00
5e3aed0b73
Add ok_or_error/1 type
2018-09-06 09:10:47 +08:00
4635921458
Rewrite the hooks module
2018-09-05 23:21:06 +08:00
c8b92a59b1
check topic alias
2018-09-05 19:06:34 +08:00
9029ee29d3
Drop will msg when receive the DISCONNECT packet whose reason code is equal to 0x00
2018-09-05 18:03:28 +08:00
47955f4309
fix bug in retain as published flag
2018-09-05 15:18:26 +08:00
aa34258f1e
Support Retain As Published in Subscription Options
2018-09-05 14:25:33 +08:00
f0f818ab1a
Fix bug in emqx_frame
2018-09-05 10:28:49 +08:00
96122cf966
Rename 'already_existed' to 'already_exists'
2018-09-04 19:14:25 +08:00
842f4fbf13
Crash when reserved flag in CONNECT packet doesn't equal to 0, and remove repeated check for protocol version
2018-09-04 11:16:15 +08:00
abc6081282
fix error spelling word
2018-09-01 11:54:28 +08:00
ec456dcc73
Fix dialyze issue
2018-08-31 20:48:57 +08:00
3f42f1271b
bug fix
2018-08-31 18:14:10 +08:00
880c6ab5fe
Fix typo
2018-08-31 17:27:36 +08:00
ec7b39f3fd
Merge pull request #1777 from emqtt/emqx30-dialyzer
...
Add banned support, and fix dialyzer errors
2018-08-31 16:58:57 +08:00
7c45d988f2
Update the spec of deliver/2 function
2018-08-31 16:57:43 +08:00
ea1ae70833
Fix errors found by dialyzer
2018-08-31 16:46:51 +08:00
e6fd7faa4b
add format_variable for disconnect packet
2018-08-31 16:24:10 +08:00
3045ec10ab
Add banned feature
2018-08-31 14:04:26 +08:00
237e65a4e0
Use emqx_mqueue:init/1 to create a mqueue
2018-08-31 10:22:16 +08:00
23e72feab7
fix reason codes
2018-08-31 01:54:25 +08:00
9406bc1fd1
fix typo
2018-08-31 01:39:56 +08:00
aa1334313c
Merge branch 'emqx30' of github.com:emqtt/emqttd into emqx30
2018-08-31 01:22:55 +08:00
25391e8c71
Rename 'Subscription-Identifiers-Available' to 'Subscription-Identifier-Available'
2018-08-31 01:22:03 +08:00
748826bdee
update access sutie and access control
2018-08-31 01:16:54 +08:00
dc9a1cd80f
Format emqx_protocol module
2018-08-31 00:48:23 +08:00
1574d85570
Merge pull request #1775 from emqtt/emqx30-feng
...
Support server_keepalive and CONNACK properties
2018-08-31 00:45:51 +08:00
07f13db453
Fix conflict
2018-08-31 00:41:48 +08:00
b6006b5947
Support CONNACK properties
2018-08-31 00:40:10 +08:00
1c94566141
add topic alias validate
2018-08-30 23:49:08 +08:00
3131acd3bc
Merge branch 'emqx30' into emqx30-feng
2018-08-30 23:41:26 +08:00
674b55e6e7
Merge pull request #1773 from tigercl/emqx30
...
Add emqx_banned test suite, and fix bugs in emqx_banned
2018-08-30 23:35:15 +08:00
0379219a04
Improve the design of session discard
2018-08-30 23:14:09 +08:00
83e11b6e39
Add emqx_banned test suite, and fix bugs in emqx_banned
2018-08-30 22:45:08 +08:00
fb8a86c5e0
delayed will message
2018-08-30 21:58:02 +08:00
cf0f55d057
delayed will message
2018-08-30 21:44:00 +08:00
4a1fdddc31
Merge pull request #1771 from emqtt/emqx30-feng
...
Only store packet_id and timestamp for qos2 message
2018-08-30 21:26:01 +08:00
78a8ccd0f2
Only store packet_id and timestamp for qos2 message
2018-08-30 21:17:20 +08:00
dd7f0dec3c
Add 'messages/qos2/expired' counter
2018-08-30 21:01:09 +08:00
2fc41b6935
fix reason code name for mqtt 4
2018-08-30 19:09:22 +08:00
cae673cf5e
Fix update_expiry/1 function_clause
2018-08-30 18:59:47 +08:00
826daace61
Align the state record
2018-08-30 18:44:58 +08:00
c49e5dfddc
Merge branch 'emqx30' into emqx30-feng
2018-08-30 18:42:29 +08:00
553a60cdec
Update 'Message Expiry Interval' property before delivering a PUBLISH
2018-08-30 18:31:37 +08:00
7b5f2577d3
Support message ttl and expiration
2018-08-30 18:30:33 +08:00
1f2bbe3eb8
Support priority queue
2018-08-30 18:29:20 +08:00
a67958adb4
Add 'messages/expired' counter
2018-08-30 18:28:40 +08:00
021d43755f
Add update_expiry/1 function
2018-08-30 18:28:02 +08:00
8a5519cafa
attrs for ws_connection
2018-08-30 14:32:31 +08:00
b0ed953708
fix emqx_session:unsubscribe bug
2018-08-30 13:56:55 +08:00
2ccec1f719
Merge branch 'emqx30' into emqx30-feng
2018-08-30 11:54:49 +08:00
2342a7db6d
Rename 'Pid' to 'ConnPid'
2018-08-30 11:48:49 +08:00
2db64cf53c
Support 'Message-Expiry-Interval property
2018-08-30 11:42:24 +08:00
2351b41f11
Add is_expired/1, check_expiry/1, check_expiry/2
2018-08-30 11:40:53 +08:00
d3ed0853ef
Rename bridge module
2018-08-30 10:41:04 +08:00
da1285ad3c
Merge branch 'emqx30' into emqx30-feng
2018-08-30 09:45:29 +08:00
53a2f93b7e
Add emqx_connection:attrs/1, emqx_protocol:attrs/1, emqx_session:attrs/1 APIs
2018-08-30 03:03:19 +08:00
98824a56c2
Remove emqx_flow_control module
2018-08-30 00:28:11 +08:00
22f8302f98
Merge branch 'emqx30-feng' of github.com:emqtt/emqttd into emqx30-feng
2018-08-30 00:03:59 +08:00
a282c7625e
Add properties for delivered messages
2018-08-30 00:03:38 +08:00
8492513094
Merge branch 'emqx30' into emqx30-feng
2018-08-29 23:11:24 +08:00
567aeb274f
Define types in emqx_types, emqx_mqtt_types modules
2018-08-29 23:08:55 +08:00
98698d318f
ws disconnect call emqx_protocol:shutdown
2018-08-29 21:39:09 +08:00
d6f3ae640d
Merge branch 'emqx30' of https://github.com/emqtt/emqttd into emqx30
2018-08-29 20:29:12 +08:00
1629215b18
Fix hook args bug
2018-08-29 20:29:03 +08:00
f4330b8af3
Add some test suites and fix bugs
2018-08-29 19:19:22 +08:00
2dc8f9c4c5
Merge branch 'emqx30-feng' of github.com:emqtt/emqttd into emqx30-feng
2018-08-29 17:55:13 +08:00
e62d215792
Shutdown and reboot ranch application
2018-08-29 17:52:55 +08:00
465963fec3
Merge branch 'emqx30' into emqx30-feng
2018-08-29 17:36:38 +08:00
1a7d60a7e3
Improve the hooks design for emqx 3.0
2018-08-29 17:27:56 +08:00
c967db409f
EMQX 3.0 UT
2018-08-29 15:50:56 +08:00
dae81037bf
Update share_sub dispatch
2018-08-29 12:58:55 +08:00
9711892f73
Fix share_sub disconnect not clear route bug
2018-08-29 10:58:34 +08:00
af21cdfd1b
Rm tmp var
2018-08-29 10:08:15 +08:00
00cb26c4e0
Support ws mqtt any version
2018-08-29 10:00:41 +08:00
013a5a9c7c
Fix emqx_protocol:clientid undefined
2018-08-29 09:30:18 +08:00
594819b752
Upgrade the publish sequence of QoS1/2 messages
2018-08-29 02:53:22 +08:00
1cf4532947
Add emqx_mountpoint module
2018-08-28 20:40:31 +08:00
545e80cd6b
Add some test suites
2018-08-28 17:53:03 +08:00
8e11845f87
Remove ignore_loop_deliver option
2018-08-28 07:36:22 +08:00
c92eba4a5e
bug fixes during UT
2018-08-28 00:27:45 +08:00
88d867b256
Merge pull request #1750 from Gilbert-Wong/emqx30
...
update emqx_broker_suite to adapt emqx 3.0 broker
2018-08-27 21:56:00 +08:00
475319b907
Merge emqx30-feng branch
2018-08-27 21:36:43 +08:00
1607e576de
Update connection, session, stats modules
2018-08-27 21:34:11 +08:00
ce3f2e4d9e
fix emqx_broker test suite
2018-08-27 21:18:00 +08:00
015901050f
change return tuple of close_session
2018-08-27 18:19:28 +08:00
224aaaf8a7
unsubscribe function should have two params
2018-08-27 17:11:54 +08:00
c5da439313
wrong unsubscribe call
2018-08-27 16:41:58 +08:00
d167a5c99a
Merge pull request #1748 from emqtt/emqx30-feng
...
Improve the emqx_listeners module
2018-08-27 16:24:59 +08:00
a19daee353
Improve the print of listener startup
2018-08-27 16:19:58 +08:00
35d821a62e
Add WS stats
2018-08-27 16:15:23 +08:00
42288ac412
The ACL file should not be undefined
2018-08-27 15:57:13 +08:00
dca292f538
Replace 'Client' with 'Credentials' map
2018-08-27 15:54:41 +08:00
a183693ac8
Merge pull request #1747 from Gilbert-Wong/emqx30
...
fix subscribe bugs and update emqx_mock_client
2018-08-27 15:36:13 +08:00
087bfe80c8
fix unsubscribe emqx_mock_client error
2018-08-27 15:24:40 +08:00
91eb79967c
Add syslog
2018-08-27 13:50:38 +08:00
28e22825ba
fix emqx subscriptions error
2018-08-27 12:35:36 +08:00
f0f1456168
fix duplicated subscribers with same topic
2018-08-27 11:21:16 +08:00
6d2b31911a
Merge pull request #1746 from emqtt/emqx30-feng
...
Use map to replace #state{} record
2018-08-27 10:35:43 +08:00
6478f811bf
Fix conflicts
2018-08-27 10:29:22 +08:00
6e8635394e
Use map to replace #state{} record
2018-08-27 10:25:15 +08:00
95d36d0204
Fix share sub bug
2018-08-27 10:15:41 +08:00
1448515e64
Fix websocket bug
2018-08-27 10:14:58 +08:00
5f65335835
Merge branch 'emqx30' into emqx_30_acl_cache_v2
2018-08-27 09:42:42 +08:00
3f811aa9ca
Add credentials/1 function
2018-08-27 09:28:49 +08:00
a369fb6960
fix subscribe bug
2018-08-26 22:02:39 +08:00
9d29dd0e10
use config enable_acl_cache
2018-08-26 18:25:17 +08:00
397179bbda
Merge branch 'emqx30' of github.com:emqtt/emqttd into emqx30
2018-08-26 16:25:02 +08:00
0e3728c940
Add emqx_types module and 'credentials' type
2018-08-26 16:24:51 +08:00
9717f9b83e
add module emqx_acl_cache
2018-08-26 15:46:22 +08:00
8cd20744be
improve cache datastruct using keys-queue
2018-08-26 13:33:00 +08:00
a904031979
acl cache using proc_dict
2018-08-26 13:30:18 +08:00
737fe19331
update acl test cases
2018-08-26 12:48:32 +08:00
ee11627828
delete duplicated subscribe function
2018-08-25 18:36:17 +08:00
8b4be236e5
fix list_to_subid error
2018-08-25 17:10:51 +08:00
36129073e8
Merge branch 'emqx30-dev' of github.com:emqtt/emqttd into emqx30-dev
2018-08-25 16:08:27 +08:00
b7c2821326
Make reason codes of SUBACK be compatible with MQTT V3.1.1
2018-08-25 16:07:57 +08:00
c2c1320083
Update compat/2 for suback reason codes
2018-08-25 16:05:58 +08:00
612c88e71e
Add 'rc' and 'subid' fields
2018-08-25 16:04:21 +08:00
1aee05ce16
Fix unsubscribe bug
2018-08-25 16:03:28 +08:00
892483891a
Merge branch 'emqx30-dev' of https://github.com/emqtt/emqttd into emqx30-dev
2018-08-25 14:32:48 +08:00
fc0f57073d
Fix share sub dispatch fail
2018-08-25 14:32:32 +08:00
5f42f88401
Pass paho zero_length_clientid test case
2018-08-25 11:51:36 +08:00
68cfcf6e0e
Pass paho mqtt interoperability tests
2018-08-24 23:19:11 +08:00
694485252a
Merge branch 'emqx30-dev' of github.com:emqtt/emqttd into emqx30-dev
2018-08-24 18:43:36 +08:00
0f052ce352
Upgrade connection, protocol and session modules for MQTT 5.0
2018-08-24 18:39:59 +08:00
36647b641f
Fix select emqx_shared_subscription fail
2018-08-24 11:38:54 +08:00
d4176461ff
Send client_pid to distinguish multiple clients
...
When a controlling process starts multiple clients that make multiple
subscriptions it may be desirable to identify from which client a
message is comming from. The topic id may not be sufficient.
2018-08-20 11:58:19 +02:00
22e8b07a3d
Receive/send messages by bridge
2018-08-19 20:31:44 +08:00
c9d604ed02
Fix the badmatch error of packet_to_msg/1
2018-08-13 16:49:53 +08:00
9145fb9ec8
Use os:timestamp/1 to get now millseconds
2018-08-12 19:14:14 +08:00
f80cd2d986
Improve the MQTT over Websocket connection
2018-08-11 17:57:19 +08:00
3d05954d5b
Optimize emqx_time module
2018-08-11 16:17:39 +08:00
d516b8c241
mochiweb -> cowboy
2018-08-09 15:19:45 +08:00
919eb9fa1e
Use cowboy to replace minirest
2018-08-09 14:27:49 +08:00
e23a6e87d8
Merge listeners, zones, bridges config
2018-08-08 19:37:57 +08:00
4005d58166
Move the 'rate_limit' option from zone to listener
2018-08-08 19:31:25 +08:00
b5a1960b63
Stop emqx_ws
2018-08-08 18:42:11 +08:00
4d9e03a803
Refactor websocket conn using cowboy
2018-08-08 18:36:14 +08:00
8418be0a5b
Use the new emqx_session:unsubscribe/2 API
2018-08-07 11:00:04 +08:00
96d251ec3c
Add encode and decode options and test suites
2018-08-07 10:27:04 +08:00
79481db659
Enhance base62 encode/decode Funs
2018-08-06 23:45:27 +08:00
645c971a07
Fix QoS tuning
2018-08-06 17:09:14 +08:00
7d0cba9427
Add MQTT 5.0 supports for connection, protocol and session modules
2018-08-06 16:33:10 +08:00
83dee0e340
Rename emqx_alarm to emqx_alarm_mgr
2018-07-19 10:53:41 +08:00
eeeed35e2a
Remove the alarm_fun arg from emqx_mqueue:new/3
2018-07-19 10:46:05 +08:00
4297033415
Fix undefined emqx_vm:schedulers/1
2018-07-19 10:19:25 +08:00
7ee54aac28
Add 'qos' field to message record
2018-07-18 23:41:00 +08:00
6c58bbab2b
Remove emqx_lager_backend module
2018-07-18 23:29:38 +08:00
ca4cdfe4ee
Move the passwd_hash/2 function to emqx-passwd project
2018-07-18 23:29:20 +08:00
62aa072f2f
Upgrade for MQTT Version 5.0 and Erlang/OTP R21
2018-07-18 13:43:17 +08:00
6f405dc128
remove ?MODULE because we don’t need it
2018-06-29 15:10:12 +08:00
385c7cd3e6
Remove 'tuple call' and be compatible with Erlang/OTP R21
2018-06-29 12:26:30 +08:00
1de94b6858
Register the default ACL module in emqx_access_control
2018-06-21 22:40:30 +08:00
b733a3bcfb
Throw mqtt_frame_too_large exception if the sent frame is too large
2018-06-12 12:10:53 +08:00
5d45d40db5
Rename emqx_mqtt module to emqx_listeners
2018-06-12 10:04:01 +08:00
055de617fc
Add emqx_message:make/4 and fix whitespace
2018-05-31 21:57:17 +08:00
bffdd2ba74
Upgrade esockd and add more test cases
2018-05-22 13:01:19 +08:00
bf253ab9b3
Support batch delete
2018-05-10 22:03:59 +08:00
c11e8f453b
Add test cases for MQTT 5.0 frame
2018-05-09 00:42:41 +08:00
31bc091873
Implement MQTT Version 5.0 client
2018-05-06 17:45:18 +08:00
1fe28a7aef
Update merge_opts/2 function
2018-04-30 12:36:17 +08:00
1630f7c9b8
Add validate/1 function
2018-04-30 12:33:29 +08:00
dc7804a2dc
Support MQTT Version 5.0 Client
2018-04-30 12:27:39 +08:00
16426346bb
Fix whitespace
2018-04-24 17:31:31 +08:00
2a4ffc6645
Add more service modules for MQTT Version 5.0
2018-04-18 16:34:23 +08:00
bbb66ff92e
Refactor the broker, router modules
2018-04-10 18:17:07 +08:00
bcdcb30af5
Merge branch 'emqx30' of github.com:emqtt/emqttd into emqx30
2018-04-09 14:32:58 +08:00
a902f508b5
Use emqx_config:get_env/1 to read env
2018-04-09 14:32:49 +08:00
c194e82807
Export dispatch/2, dispatch/3 for RPC
2018-04-09 14:31:34 +08:00
71acf91ace
Replace lager with emqx_log
2018-04-09 12:34:53 +08:00
5f32f3c560
Pass the paho interoperability tests
2018-04-08 16:37:30 +08:00
bfb23ff0b2
Improve the design of MQTT session management
2018-04-08 15:16:05 +08:00
39548cc399
Improve the session management
2018-04-04 15:28:01 +08:00
6459481024
Add multicall/4 function
2018-04-03 20:22:01 +08:00
2eed46310c
Misc fix for the MQTT Version 5.0
2018-03-30 17:18:08 +08:00
9976327c8d
Add emqx_mqtt module
2018-03-23 18:13:09 +08:00
f007f69abe
Update emqx.app.src
2018-03-23 16:45:50 +08:00
56b88dd7f7
Improve the design of session management
2018-03-23 16:39:23 +08:00
282e341433
EMQ X R3.0 - Improve the design of pubsub and router
2018-03-21 16:48:52 +08:00
f218c6a35d
Add a locker module
2018-03-10 13:28:14 +08:00
22350f9117
Depends on canel-lock library
2018-03-09 13:26:46 +08:00
6a957e1b33
Support MQTT Version 5.0
2018-03-02 20:18:27 +08:00
d7eae533ac
Merge the emqx-mqtt5 library
2018-02-28 21:22:39 +08:00
f7f0f27e4d
Parse and serialize MQTT 5.0 protocol packets
2018-02-27 23:45:55 +08:00
a8aeb5ac17
Rename the 'mqtt_route' record to 'route'
2018-02-27 09:13:14 +08:00
f4fd6efe16
Merge the emqx-common, emqx-router libraries
2018-02-26 23:29:53 +08:00
d5893ba2be
Replace gen_server2 with gen_server for we cannot trace the size of drain queue
2018-02-26 13:24:29 +08:00
fcb2ec8427
Merge the latest enterprise branch
2018-02-24 15:56:32 +08:00
b63c34ab14
Merge the latest master branch
2018-02-24 11:27:09 +08:00
a22e225e67
Merge pull request #1475 from HJianBo/develop
...
Fix #1473 for supporting special chars in URL path
2018-01-28 15:32:56 +08:00
707d338b0e
Merge branch 'develop' into ws-proxy
2018-01-28 15:11:08 +08:00
3146cdda92
Fix #1473 for supporting special chars in URL path
2018-01-28 14:25:41 +08:00
0f717e5b3b
Merge branch 'develop' of github.com:emqtt/emqttd into develop
2018-01-23 11:10:27 +08:00
701c632e07
Fix issue #1461 - keep the retain flag for new subscription
2018-01-23 11:09:42 +08:00
a3e97f798b
Update Copyright to 2018
2018-01-16 08:57:46 +08:00
56195670c6
Misc fix
2018-01-12 10:45:36 +08:00
bfa9fc675c
Merge pull request #1420 from HJianBo/issue_1216
...
Fix issue #1216
2018-01-07 14:02:54 +08:00
fdc55de509
Change the type of 'mqtt.bridge.ping_down_interval' to ms duration
2018-01-04 16:09:45 +08:00
86fc80b983
Change the type of 'mqtt.broker.sys_interval' to ms duration
2018-01-04 16:09:10 +08:00
0a7e93ea90
Export funtion fix #1428
2018-01-03 10:29:51 +08:00
ad26eff421
Format print log
2018-01-03 10:27:51 +08:00
5fbbff46b1
Fix issue #1216 , redeliver pubrel packet now
2017-12-28 17:57:32 +08:00
953a7628a3
Version 2.3.3
2017-12-28 11:34:29 +08:00
4c8b43e05d
Improve impletament of emqttd_topic:match/2
2017-12-27 15:11:55 +08:00
d5c54276e2
Fix issue #1398
2017-12-27 14:55:36 +08:00
bcec25092b
Merge version 2.3.2 to X edition
2017-12-26 21:09:24 +08:00
db954aeb6d
Support X.509 certificate based authentication with HAProxy
2017-12-15 19:23:50 +08:00
6f64eb469c
Remove emqttd_ssl.erl
2017-12-07 17:58:24 +08:00
b98007659e
Merge the master branch
2017-12-07 17:57:18 +08:00
73836939c8
Support for TLS with client certificate based authentication
2017-12-07 17:42:32 +08:00
6e5134a8b2
Merge with the enterprise edition
2017-12-07 16:24:48 +08:00
f1640f5b85
Merge emq24 to X branch
2017-12-07 11:02:44 +08:00
9f1c3a5899
Compatible with esockd 4.x
2017-12-06 14:42:26 +08:00
bcf345efbe
Fix compile fail
2017-12-06 10:27:55 +08:00
ddf2965651
Rm emqttd.app.src
2017-12-06 10:26:19 +08:00
24f05adb1a
Fix compile fail
2017-12-06 10:19:46 +08:00
c3c5589452
Version 2.3.2
2017-12-06 10:01:42 +08:00
51533dbe9e
Shutdown the connection if an error occurred when sending data
2017-12-05 23:41:40 +08:00
a42fcb2c39
Fix conflicts
2017-12-05 16:34:18 +08:00
b8e0a4d5c4
Bump version to 2.3.1
2017-12-03 00:43:42 +08:00
0fe530a502
Depends on the develop branch of mochiweb
2017-12-02 18:00:56 +08:00
4915195b1e
Fix issue #1335 - Forward real client IP using a reverse proxy for websocket
2017-12-02 17:59:16 +08:00
70570dd943
Merge branch 'develop' into ws_proxy
2017-12-01 22:22:20 +08:00
5006dbba6e
Add ws/wss proxy cofingurations for getting client original ip address
2017-12-01 22:12:27 +08:00
c308037b1a
Remove the unnecessary transactions to optimize session management
2017-12-01 17:16:59 +08:00
d2a4e2c615
Should not exit arbitrarily if clientid conflicts in mnesia
2017-12-01 15:46:42 +08:00
d9500412bf
Update the topic's statistics
2017-12-01 09:10:46 +08:00
ee5c33d0bd
Fix the 'no function clause' exception for issue #1293
2017-11-29 22:23:59 +08:00
26fb809dbe
Fix issue#1293 - the retained flags should be propagated for bridge.
2017-11-29 14:09:46 +08:00
223f3d4da5
Remove RPC configurations
2017-11-22 16:44:00 +08:00
38c33e9c8b
Merge with emqx
2017-11-21 22:41:05 +08:00
845c5eddc1
Merge with emqx
2017-11-21 22:41:02 +08:00
e52c303014
Merge develop to X
2017-11-21 14:25:35 +08:00
2cec86eba7
Merge with version 2.3.0
2017-11-21 14:14:12 +08:00
db3a54e31a
Fast close the invalid websocket in init/1 function
2017-11-20 14:15:51 +08:00
14771cdaee
Fix issue #1340 - erlang:demonitor/1 the reference when erasing the monitor
2017-11-20 10:10:32 +08:00
6028d6e83e
Show local route
2017-11-19 14:25:54 +08:00
945f925136
Refactor the subscription_list function
2017-11-19 01:15:22 +08:00
8462fa8e89
Display local route
2017-11-18 17:21:13 +08:00
f01deec950
Update the 'api/v2/subscriptions' API
2017-11-18 13:23:51 +08:00
1d0e17b89c
Improve the print of 'subscriptions' CLI
2017-11-18 12:25:00 +08:00
d58b8bed3c
Fix the 'subscriptions add <ClientId> <Topic> <Qos>' CLI
2017-11-18 11:48:44 +08:00
405d5d9d29
Fix the 'subscriptions' CLI
2017-11-18 11:17:19 +08:00
11a41166d2
Fix the function spec: '{error, any()}' -> '{error, term()}'
2017-11-17 21:13:20 +08:00
62d4f9f031
Bump version to 2.3.0
2017-11-17 20:53:07 +08:00
8f00e28576
Improve the pubsub design and fix the race-condition issue
2017-11-17 20:51:51 +08:00
cae743803b
Improve the process logic of DUP flag ( #1319 ).
2017-11-03 17:49:52 +08:00
279b96f146
Fix issue #1319 , reset DUP=0 when recv DUP=1 PUBLISH Message
2017-11-02 09:48:37 +08:00
49d91cf694
Rename 'message.offline' hook to 'message.dropped'
2017-10-31 15:19:53 +08:00
84d8eae37e
Fixed issue #1314 . re-sent retained messages when create/replace Subscription
...
- re-sent message when create a new Subscription relationship
- re-sent message when replace an existed Subscription with different Qos
2017-10-31 13:23:54 +08:00
586c3a243a
Fix retained message is not sent for Subscribe to existing topic
2017-10-28 22:07:06 +08:00
c87c49ede0
Updated trace logging level
2017-10-21 14:49:56 +08:00
c43cae4348
Bug fixed for users api
2017-10-11 20:08:01 +08:00
2354a3dd5d
Fix the building errors
2017-10-10 15:50:40 +08:00
5d30ceccd1
Fix passwd_hash return type error
2017-10-10 14:15:53 +08:00
735211fd02
Merge with EMQ X project
2017-10-09 23:29:05 +08:00
4b8cd18f5d
Merge with EMQ X project
2017-10-09 19:43:06 +08:00
54534967bd
Fix Dashboard not showing data
2017-10-09 18:08:46 +08:00
88c77cf4c2
Auth failure not publish the will message
2017-10-09 18:07:09 +08:00
d9f14dacaf
Fix dashboard not showing data bug
2017-09-25 14:59:58 +08:00
e57121a660
Fix string:split undefined issue
2017-09-12 21:34:43 +08:00
f6025404e3
Update clean_acl_cache API
2017-09-12 10:57:04 +08:00
ee9fc5cb0e
Review code
2017-09-09 21:21:30 +08:00
424aea2878
Review code
2017-09-09 21:00:17 +08:00
8091c07d3c
Review code
2017-09-09 20:55:57 +08:00
85f9a8cb70
Fix read plugin configuration not find schema file
2017-09-08 23:23:48 +08:00
7260b17cb5
Plugins configuration insert to ets table
2017-09-06 17:17:29 +08:00
d3f52898ee
Add Hot configuration plugin
2017-09-05 16:52:07 +08:00
ed29c3273d
Review code
2017-08-21 16:16:28 +08:00
9a4a6885d9
Update api list
2017-08-21 15:09:45 +08:00
5bec24d19b
Update modify_config url
2017-08-18 23:28:33 +08:00
f6b9ce84e5
Update kick_client API
2017-08-18 11:44:11 +08:00
9e6c63b91b
REST API add modify_config/config_list
2017-08-17 15:51:20 +08:00
d50ce9f6c0
Fix compile warning
2017-08-16 12:10:46 +08:00
4ff7d4eead
Fix ctl set env fail
2017-08-16 11:25:11 +08:00
34e5d746d1
Fix compile fail
2017-08-15 12:33:09 +08:00
303db5ccbd
Add clean_acl_cache API
2017-08-15 12:18:31 +08:00
f978bae86a
TODO: How to persist the configuration
2017-08-14 09:32:39 +08:00
64af3271c2
Fix rest_api get monitoring/nodes error
2017-08-12 22:00:33 +08:00
f28db8b4c7
Format code
2017-08-12 12:51:02 +08:00
9b61fea1d1
Update auth spec
2017-08-11 15:40:33 +08:00
f11967288e
Add emqttd_broker info API
2017-08-11 14:56:56 +08:00
f4381155f8
Format code
2017-08-11 09:53:06 +08:00
701ee3e8dc
Add CLI set/get env
2017-08-10 18:19:20 +08:00
7c1ee6610d
Add http management APIs
2017-08-09 10:14:29 +08:00
1c63bdd90d
APIs for hot reload of configuration
2017-08-07 18:28:32 +08:00
88f84a4a0c
Support to configure keepalive backoff
2017-08-07 18:27:16 +08:00
925e35dcbd
Remove the fullsweep_after option
2017-08-07 12:15:52 +08:00
8325056061
Authorize HTTP Publish API with clientId
2017-07-26 13:16:46 +08:00
f25661d3cd
Merge pull request #887 from chimit/master
...
Add ClientId parameter into the auth on HTTP Publish
2017-07-26 13:02:02 +08:00
c4464954b0
Fix the 'case clause matching' exception
2017-07-24 09:34:22 +08:00
6b0571d76c
Fix the undefined error
2017-07-23 20:49:58 +08:00
15a081c9bb
Improve the Autocluster design
2017-07-23 18:07:53 +08:00
081717be92
Add autocluster lock
2017-07-21 15:44:38 +08:00
c1bce429d9
Load plugins after autocluster
2017-07-21 13:07:04 +08:00
96777a4da8
Start listeners after autocluster
2017-07-21 12:43:28 +08:00
7f22265e31
Use global:trans/2 to clean routes and sessions
2017-07-20 14:22:18 +08:00
d6d08d6d5e
Ensure to start ekka
2017-07-18 18:49:38 +08:00
437b26718b
Call ekka_autocluster:bootstrap/0 to build the cluster
2017-07-18 18:40:03 +08:00
2b54745f69
v2.3
2017-07-10 15:28:13 +08:00
523dd9c8b0
Merge pull request #1145 from emqtt/master
...
Merge emq22
2017-07-10 13:07:32 +08:00
081f5dbe6e
Format code
2017-07-08 08:51:44 +08:00
e3d414089f
Fix the usage of listeners restart/stop CLI
2017-07-07 09:19:30 +08:00
e42e71dcf7
Format code
2017-07-07 08:56:07 +08:00
4b63b2c098
Format code
2017-07-06 22:15:34 +08:00
3488d14776
Add 'undefined' from a record field's type
2017-07-06 18:59:54 +08:00
55b77af044
Merge branch 'develop' of https://github.com/emqtt/emqttd into develop
2017-07-06 17:53:31 +08:00
e675959d57
Fix received/1 and sent/1 function spec
2017-07-06 17:28:49 +08:00
53145bbbba
Update subscriptions/1 function spec
2017-07-06 17:01:27 +08:00
87d2a7ca85
Review code
2017-07-06 16:17:36 +08:00
7054d2c575
Rename reopen -> restart
2017-07-06 16:05:02 +08:00
5433af4c92
Add reopen/close ctl command
2017-07-06 14:49:17 +08:00
a427a53a30
Fix error exit code from emqttd_ctl
2017-07-06 11:25:05 +08:00
934287b926
Fix error exit code from emqttd_ctl
2017-07-06 10:52:27 +08:00
88797062a4
Add function restart_listener
2017-07-01 17:51:55 +08:00
8a804c56f3
Monitor/Unmonitor membership events
2017-06-28 15:51:24 +08:00
cc6696f8cb
Tune the log level
2017-06-25 07:11:36 +08:00
50c312e736
Merge master branch
2017-06-22 12:53:33 +08:00
0b58719342
Monitor changes of membership
2017-06-22 12:50:55 +08:00
ae36a8c8c2
Update spec #1106
2017-06-21 10:11:34 +08:00
1f3bab2bcb
Integrate with ekka library, use ekka:subscribe/1 to replace mnesia:subscribe/1
2017-06-16 16:02:36 +08:00
1e205720cc
Refactor: rename 'tick_tref' field to 'ticker'
2017-06-16 16:01:27 +08:00
adfd34852b
Register 'fun emqttd:reboot/0'
2017-06-16 14:52:40 +08:00
9b646d8cbc
Integrage with 'ekka' library
2017-06-16 12:30:09 +08:00
37b625aa57
Format code
2017-06-13 21:13:57 +08:00
88d466eb1a
remove from cluster, delete the node in extra_db_nodes
2017-06-13 21:02:38 +08:00
bbcc082a0d
Add stop api listener function
2017-06-13 11:15:26 +08:00
f18051c340
Add stop api listener function
2017-06-13 11:06:35 +08:00
fa138882a3
Merge the updates of test case
2017-06-13 10:51:56 +08:00
79c2fa631e
Fix the issue that we cannot remove a down node from the cluster
2017-06-13 10:35:22 +08:00
a5cac277c1
Add cluster_nodes/1 function
2017-06-13 10:33:56 +08:00
c0bb20c2d9
Remove bridge command qos option
2017-06-12 22:52:23 +08:00
53f5188cbb
Fix the race condition issue caused by unregister_session/1
2017-06-12 19:13:58 +08:00
4888702712
Remove bridge command qos option
2017-06-12 15:13:54 +08:00
1a8cc2e146
Add http to listen on port 8080 for the http REST API
2017-06-09 14:54:03 +08:00
0f7a66f810
Force gc call emit_stats
2017-05-26 16:44:44 +08:00
dc2e6ab53c
Hash type add bcrypt
2017-05-26 12:31:07 +08:00
c64f172174
Emq-WebSocket-Protocol -> EMQ-WebSocket-Protocol
2017-05-19 16:55:14 +08:00
0ffa2d00d0
Add a 'websocket_protocol_header' option to fix the missing 'Sec-Websocket-Protocol' header of WeChat WebSocket Connection
2017-05-19 16:41:27 +08:00
94402f4297
Format code
2017-05-19 10:24:36 +08:00
96562dfc59
Format code
2017-05-19 10:22:07 +08:00
9c5ce15f46
Fixed http publish API missing params
2017-05-19 10:13:01 +08:00
8d4ec32d1a
Fixed http publish API missing params
2017-05-19 10:09:34 +08:00
798c60f269
Rollback code
2017-05-19 09:26:52 +08:00
61fa9f3f89
Cli listeners start add flag --backlog
2017-05-18 16:44:46 +08:00
3e1c69dff1
Add cli listeners start|stop
2017-05-18 16:35:49 +08:00
caaf66311d
Cli show all usage
2017-05-18 09:24:15 +08:00
95232189cd
Invalid params
2017-05-17 17:15:21 +08:00
1f2cd40237
Invalid params
2017-05-17 17:12:19 +08:00
8853e43275
cli query -> show
2017-05-17 16:37:55 +08:00
d5ccb9f92f
Cli command support --format=json output
2017-05-17 16:27:18 +08:00
06d291e354
Update Cli command
2017-05-17 10:18:09 +08:00
2d6104fbd9
Ctl use clique
2017-05-11 16:02:38 +08:00
161e5a2b5b
Http publish mochiweb_request:parse_post(Req) -> Req:recv_body
2017-05-08 18:13:52 +08:00
73d84bef5e
Update SUITE conf
2017-05-05 14:53:06 +08:00
cdbcc84d23
emqttd.app.src add bcrypt
2017-04-27 09:22:02 +08:00
ba0c08517f
v2.2
2017-04-25 10:41:43 +08:00
87d3bb1419
Merge branch 'emq22' into emq20
2017-04-25 08:59:05 +08:00
7388be0180
Merge pull request #1009 from emqtt/develop
...
Change subscription to subscriptions
2017-04-20 14:08:23 +08:00
1cfa25861f
Change subscription to subscriptions
2017-04-20 14:06:56 +08:00
a091d3a112
Merge pull request #1007 from emqtt/develop
...
Version 2.1.2
2017-04-20 11:21:05 +08:00
dcecd7d8ae
Version 2.1.2
2017-04-20 11:19:26 +08:00
3c9cde59c7
Merge pull request #1004 from emqtt/develop
...
Fix crash caused by duplicated PUBREC packet
2017-04-20 10:15:30 +08:00
7ca6cbadcf
Duplicated PUBACK Packet
2017-04-18 17:32:00 +08:00
9d3676884c
Fix duplicate send pubrec packet
2017-04-18 17:19:04 +08:00
aa360d4378
Fix duplicate send pubrec packet
2017-04-18 16:44:19 +08:00
7bbc3adfcb
Merge pull request #1002 from emqtt/develop
...
Fix sessions list command
2017-04-17 10:02:38 +08:00
9157f824e5
Fix sessions list command
2017-04-15 23:52:54 +08:00
455a978c96
Merge pull request #996 from emqtt/develop
...
Fix the subscrptions print
2017-04-13 15:10:57 +08:00
0cbca5f4c0
Fix the subscrptions print
2017-04-13 15:09:48 +08:00
bc280701cd
Merge pull request #994 from emqtt/develop
...
Version 2.1.1
2017-04-13 10:26:10 +08:00
b10938c90a
Version 2.1.1
2017-04-13 10:24:50 +08:00
ca676880a8
Support bcrypt
2017-04-11 16:39:52 +08:00
7d618e78ff
support bcrypt
2017-04-11 16:02:21 +08:00
6f02d775e4
Merge pull request #991 from emqtt/develop
...
Support HEAD method for health check
2017-04-10 22:16:22 -05:00
5476288ab3
Merge branch 'develop' of https://github.com/emqtt/emqttd into develop
2017-04-11 09:40:46 +08:00
43cc90ceae
bridge message qos default 0
2017-04-11 09:40:31 +08:00
e6df089ecb
Fix issue #984 - support HEAD method for health check
2017-04-10 13:37:50 +08:00
b839fdc275
Merge pull request #986 from emqtt/emq20
...
merge emq20 branch code
2017-04-10 12:40:26 +08:00
45ca461fd9
Add ignore self publish message
2017-03-30 14:41:29 +08:00
5c866d91b4
support cascading multiple acl modules
2017-03-30 09:43:35 +08:00
ca8e7e6423
Merge branch 'develop' into emq20
2017-03-29 17:39:36 +08:00
43207f86ea
Use stop/2 to count the shutdown reasons
2017-03-29 17:38:43 +08:00
9240a0355a
Fix issue #963 - shutdown if session process exited
2017-03-29 16:36:17 +08:00
300bfce372
Merge pull request #964 from emqtt/develop
...
Fix issue #963 - shutdown if session process exited
2017-03-29 16:31:51 +08:00
4f0bd74f87
#777
2017-03-29 15:28:24 +08:00
2f01400f38
correct licence in app.src
2017-03-24 15:58:51 +05:30
440307081b
Check if the node is in cluster before remove
2017-03-23 18:37:04 +08:00
f194f92418
Shutdown the connection if no more data received
2017-03-23 16:30:23 +08:00
3c8de09ba3
Rename the env 'queue' to 'mqueue'
2017-03-23 15:20:32 +08:00
06100ae6d5
Define 'MQueue' macro
2017-03-23 15:15:45 +08:00
690f27a8b4
Support 'mount point'
2017-03-23 15:10:24 +08:00
496d046d52
Improve the mqueue design
2017-03-23 15:07:06 +08:00
0d617c17e0
Use the emqttd_protocol:init/4 API
2017-03-23 15:06:14 +08:00
0b13cd78e6
Version 2.2
2017-03-22 10:48:24 +08:00
2e6e97b006
Fix the syntax error
2017-03-13 16:30:41 +08:00
82bb7766ac
Add env, maintainers, licenses properties
2017-03-13 15:55:00 +08:00
d099d0b53c
Add emqttd_gc:maybe_force_gc/3 API and tune the min hibernate interval
2017-03-13 15:36:58 +08:00
05396f0ade
Add pbkdf2 dependencies and fix the building errors
2017-03-13 13:30:49 +08:00
spring2maz