b0e2b7db0c
Support inter-node messages via RPC cast
2019-07-27 12:59:07 +08:00
70be888f3b
Compat windows ( #2665 )
2019-07-05 23:10:13 +08:00
481458d8ec
Add plugin type
2019-06-21 19:52:53 +08:00
31e95b56c4
Update Copyright to 2019
2019-01-29 10:43:25 +08:00
ae743ad1f0
Rewrite emqx_mqueue.erl
...
Fixed bugs:
- Priority queue lack of a `len + 1` logic in `in/2`
Changed behaviors:
- Topics not found in priority table (from config) will be treated with default priority,
instead of hasing topic name to a priority number.
- Default priority is now configurable (it was always lower than all configured priorities)
- The dropped message due to reaching `max_len` is now returned from `in/2`,
so the queue owner (`in/2` caller) can perform autopsy on it
2018-10-27 14:21:53 +02:00
4c40f75f4b
Request & Response (broker and client) ( #1819 )
...
Add request & response support for CONNECT & CONNACK
Prior to this change, there is no validate and specified process for
Request-Response-Information and Response-Information
Also added basic Request/Response functionality to emqx_client implementation
2018-10-18 19:21:05 +02: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
83e11b6e39
Add emqx_banned test suite, and fix bugs in emqx_banned
2018-08-30 22:45:08 +08:00
567aeb274f
Define types in emqx_types, emqx_mqtt_types modules
2018-08-29 23:08:55 +08:00
6478f811bf
Fix conflicts
2018-08-27 10:29:22 +08:00
95d36d0204
Fix share sub bug
2018-08-27 10:15:41 +08:00
0e3728c940
Add emqx_types module and 'credentials' type
2018-08-26 16:24:51 +08:00
0f052ce352
Upgrade connection, protocol and session modules for MQTT 5.0
2018-08-24 18:39:59 +08:00
4d9e03a803
Refactor websocket conn using cowboy
2018-08-08 18:36:14 +08:00
7d0cba9427
Add MQTT 5.0 supports for connection, protocol and session modules
2018-08-06 16:33:10 +08:00
b110a154ef
Upgrade header files for EMQ X 3.0
2018-07-18 14:27:11 +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
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
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
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
6a957e1b33
Support MQTT Version 5.0
2018-03-02 20:18:27 +08:00
aef5a20697
Add 'message' and 'delivery' record
2018-03-01 21:04:00 +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
f4fd6efe16
Merge the emqx-common, emqx-router libraries
2018-02-26 23:29:53 +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
a904dfd4f2
Comment the ERTS_MINIMUM macro
2017-12-07 16:26:32 +08:00
4b8cd18f5d
Merge with EMQ X project
2017-10-09 19:43:06 +08:00
terry-xiaoyu