c037c2cf6c
chore: release 4.3.13-rc.3
2022-03-31 17:54:20 +08:00
65e11bcb01
chore: bump vsn for 4.4.2-rc.1
2022-03-24 14:26:52 +08:00
61d3ed31e8
chore: bump vsn to 4.3.13-rc.2
2022-03-24 14:23:19 +08:00
02aa665e54
chore: bump version to prepare the next release
2022-03-01 11:41:52 +01:00
e13f2101f2
chore: prepare for v4.4.1 release
2022-02-21 11:34:23 +01:00
14575fed63
chore: prepare for release v4.4.1-rc.1
2022-02-21 08:13:53 +01:00
82285980a7
chore: bump version
2022-02-18 19:14:30 +08:00
0a66d40e39
chore: prepare for 4.4.0-rc.2 release
2022-02-17 11:21:22 +01:00
b09a38d53f
chore: update release to 4.3.12
2022-02-10 18:30:22 +08:00
e768c601ab
chore(release): update emqx release version
2021-12-21 17:05:22 +08:00
dc9631514d
chore: ensure version bump for dashboard app
2021-12-17 20:28:54 +08:00
daeac6edf4
chore(release): update emqx release version
2021-11-18 15:26:36 +08:00
2a55a712d1
build: prepare for 4.4-alpha.1 release
2021-11-17 13:58:09 +01:00
d05e2ff0b1
Merge remote-tracking branch 'origin/main-v4.3' into main-v4.4-alpha.1
2021-11-15 13:41:51 +01:00
04a4462f1e
chore(release): update version to 4.3.10
2021-11-12 10:36:27 +08:00
835ad52498
feat(trace): http api for trace ( #6052 )
...
* feat(trace): add http trace API
* feat: sub/unsub trace topic
* chore(trace): stream log use _page and _limit
* fix: elvis warning
* fix: mod_trace test failed
* fix: http api meta rename _page/_limit to _page/_limit
* fix: clientid string not working
* fix: add emqx_mod_trace to module
* fix(trace): fixed by review suggestions
2021-11-11 14:54:40 +08:00
fec83590a6
chore: bump release version to 4.4.0
2021-11-08 21:38:18 +01:00
f00e254bdf
chore(release): update version to 4.3.9
2021-11-02 18:26:57 +08:00
aaa7cd0a44
chore(release): update emqx release version
2021-09-06 10:55:02 +08:00
87ee94b6f2
chore(version): update emqx version to 4.3.7
2021-08-04 18:44:47 +08:00
07f58c0e9e
chore(release): update emqx release version
2021-07-28 16:45:54 +08:00
0c66fcef00
chore(release): update emqx release version
2021-06-28 11:14:33 +08:00
bfc6c3aa42
chore(release): update emqx release version
2021-06-23 17:52:42 +08:00
42a6f2aba5
fix(mqttsn): fix proto_name to MQTT-SN instead of MQTT ( #4961 )
2021-06-11 11:08:24 +08:00
4891c4f8de
chore(release): update emqx release version
2021-06-05 15:34:07 +08:00
96466aba40
chore(release): update emqx release version
2021-05-27 17:54:50 +08:00
ff4ac624d0
chore(release): update emqx release version
2021-05-14 11:28:12 +00:00
80a93c225f
build: prepare for 4.3.0
2021-05-06 21:05:39 +02:00
bf4baf708a
fix(emqx_packet): list element index out of range
2021-05-04 09:24:54 +02:00
883614e8c3
chore(release): update emqx release version
2021-04-26 20:42:36 +08:00
bc6a87946c
refactor(emqx_trie): store only prefixes
...
This commit refactors emqx_trie implementation
with mainly two changes
1. Deleted the edge table.
In the old implementation, trie consist of nodes and edges.
e.g. for topic 'a/b/+/d', node 'a' with edge 'b'
points to node 'a/b' and so on.
However, edges can be computed at runtime,
so there is no need to store them in a table.
2021-04-26 14:18:40 +02:00
6354e75626
chore: update copyrights
2021-04-23 20:43:00 +02:00
cf16a822b8
chore(release): update emqx release version
2021-04-16 17:07:24 +08:00
9e219ed68d
chore(release): update emqx release version
2021-03-30 18:51:02 +08:00
6c77fa1bf7
fix(emqx_channel): Receive Maximum spec compliance
...
According to MQTT 5.0 specification
If the Receive Maximum value is absent then its value defaults to
65,535.
2021-03-29 09:42:07 +02:00
b10a60cddb
fix(conninfo): Ensure receive_maximum do not exceed limit
2021-03-29 09:42:07 +02:00
52743839d0
chore(release): update emqx release version
2021-03-26 14:50:56 +08:00
4ce7229382
chore(release): update emqx release version
2021-03-23 23:09:38 +08:00
00a2daba19
chore(build): add more enterprise build support
2021-03-06 10:56:07 +01:00
b12d4f481f
chore(script): remove the prefix of pkg-vsn.sh
2021-03-06 10:40:32 +08:00
9b3ab169ce
chore(versioning): detach package version from emqx app version
2021-03-04 20:24:58 +01:00
d437f9f228
chore(elvis): fix elvis warnings
2021-01-14 15:46:16 +08:00
2b481dabe7
Fix some dialyzer warnings ( #3988 )
2021-01-05 20:49:50 +01:00
43b49edd28
feature(alarm): new design for alarm
2020-07-31 18:07:20 +08:00
e3489b9d46
refactor(style): improve all types declaration
...
- Add dialyzer for code analysis
- Correct all the module type declarations
- Use `-type()` to declaration a type instead of `-opaque`
(It is advantageous to the code dialyzer)
BROKEN CHANGES:
- Add a ?DEFAULT_SUBOPTS for emqx_broker:subscribe/1,2,3
- Remove the needless internal function `emqx_vm:port_info(PortTerm, Keys)`
2020-06-18 17:38:34 +08:00
6ad65d587e
feature(properties): add properties in message header
...
1. Add MQTT5.0 properties when invoking the hooks.
- Add a new key `properties` into the message header:
We used to put all of the properties into the `#message.headers`:
```erlang
#message{headers = #{'User-Property' => {<<"reason">>,<<"normal">>},
'Message-Expiry-Interval' => 60,
allow_publish => true}
```
I put them instead under a single key:
```erlang
#message{headers = #{properties =>
#{'User-Property' => {<<"reason">>,<<"normal">>},
'Message-Expiry-Interval' => 60},
allow_publish => true}
```
Note that the column `properties` may contain all the properties for
Publish and Will messages.
- Add `disconn_props` into the `Channel.conninfo`
- Add `puback_props` also into the message header:
```erlang
#message{headers = #{puback_props =>
#{'User-Property' => {<<"reason">>,<<"normal">>}},
allow_publish => true}
```
2. Change the data type of `#message.headers` and `#message.flags` to map.
It used to support `undefined`.
2020-06-17 18:46:26 +08:00
3b537760d5
Read new configuration items when plugins is loaded
2020-03-23 15:23:38 +08:00
7ea75f4289
Update copyright
2020-01-03 18:31:08 +08:00
9786dd5305
Support configuration log line
2019-12-20 15:40:58 +08:00
0c377c67cd
Use 'erlang:system_time' to replace 'os:timestamp' ( #3088 )
...
Use 'erlang:system_time/1' to replace 'os:timestamp/0'
2019-12-09 16:27:25 +08:00
9c3273a2c6
Improve the process of handling MQTT control packets ( #3079 )
2019-12-06 19:51:06 +08:00
b7cafc0ba0
Update record banned
2019-11-15 14:55:14 +08:00
d004a5b68e
Rename 'client_id' field to 'clientid'
2019-09-29 16:46:27 +08:00
2790ab318d
Rename 'client_id' field to 'client'
2019-09-24 13:53:46 +08:00
2ed9e9480e
Remove the default value of 'headers' field
2019-09-19 11:18:04 +08:00
2089c2108e
Default rap is 0
2019-09-06 20:32:10 +08:00
3038bd4570
Add support for logger per module filtering ( #2873 )
...
Add mfa to the meta data to suppor the Erlang Logger's per module / per app filtering
2019-09-06 11:03:47 +08:00
847375d2fb
Improve connection and channel modules ( #2860 )
...
Improve the connection and channel modules
2019-09-05 14:17:15 +08:00
c69a2b1b48
Ensure session expiration ( #2825 )
...
Ensure session expiration
2019-08-23 09:35:29 +08:00
79744af681
Wrapper proper test cases into common test cases ( #2785 )
...
* Wrapper proper test cases into common test cases
* Improve test cases for reason code module (#2789 )
* Split 3 proper tests into 3 ct cases
* Improve test cases for client, rpc and request-response
* Add psk suites to increase coverage
* Add sys test cases
2019-08-16 18:07:12 +08:00
91a8dbda56
Fix conflicts
2019-08-09 16:41:11 +08:00
ef9cbe51eb
Fix conflict
2019-08-02 10:41:46 +08:00
c95a89ed1e
Merge branch 'nchannel' into develop
2019-07-31 14:03:48 +08:00
b0e2b7db0c
Support inter-node messages via RPC cast
2019-07-27 12:59:07 +08:00
c091e89796
Remove the unnecessary include/emqx_client.hrl
2019-07-23 10:56:14 +08:00
a6262ffb30
Remove the 'rc' field from DEFAULT_SUBOPTS
2019-07-22 17:07:58 +08:00
dfa2c2370e
Define 'Otherwise' macro
2019-07-13 12:25:25 +08:00
70be888f3b
Compat windows ( #2665 )
2019-07-05 23:10:13 +08:00
42da51e1c5
Implement batch delivery for the new channel design
...
- Implement a new emqx_channel module
- Improve the emqx_frame:serialize/2 API
- Improve the emqx_connection, emqx_ws_connection modules
2019-07-02 13:40:52 +08:00
177dc44155
Define 'Otherwise' macro
2019-07-02 13:39:23 +08:00
f32a415a83
Merge branch 'channel3'
2019-06-25 15:55:31 +08:00
795fe4e0bc
Add 'PUBLISH_PACKET(QoS, Topic, PacketId)' macro
2019-06-25 14:29:26 +08:00
481458d8ec
Add plugin type
2019-06-21 19:52:53 +08:00
3877c4db1a
Merge branch 'channel2' into channel3
2019-06-18 16:49:26 +08:00
7774b85f81
Implement the channel architecture
2019-06-18 15:03:51 +08:00
c64751a53c
Support module level logger header
2019-06-18 14:37:32 +08:00
21162f88b8
Update copyright
2019-06-18 14:27:06 +08:00
1d88f8fd9e
Improve the emqx_connection, emqx_ws_connection and emqx_frame modules ( #2611 )
...
* Adopt channel architecture and improve the MQTT frame parser
* Update the test cases for emqx_channel, emqx_protocol
- Improve emqx_client to Use the new emqx_frame:parse/2
- Update the ct suites for emqx_channel, emqx_ws_channel
* Fix test case
2019-06-14 12:44:27 +08:00
d386b27e8a
Adopt channel architecture and improve the MQTT frame parser
2019-06-11 23:18:38 +08:00
bcbb4b68e9
Add flapping detect feature
2019-04-19 16:34:33 +08:00
48450d1d37
Move request response out of emqx client ( #2293 )
...
* Delete response_topic_prefix
The Response-Infomation in CONNACK was misinterpreated, it should
not be a broker's global config, instead, it should be per-client
or even per-session prefix/suffix mechanism
* Delete request-response code from emqx_client
* Add request-response test code
* meck as default dependency --- temp workaround for dep-vsn-check
2019-03-13 11:27:25 +08:00
b1ca0120a2
Move bridge modules out of bridge directory ( #2273 )
2019-02-28 17:04:39 +08:00
771f8c052a
Merge branch 'develop' into introduce-new-bridge-impl
2019-02-28 15:14:40 +08:00
08204fc7a8
Improve the emqx_connection module using gen_statem behaviour ( #2235 )
2019-02-28 15:08:29 +08:00
911a813891
Fix copyright and unify log method
2019-02-28 11:18:12 +08:00
efc9e34033
Make use of BUMP_PACKET_ID the only way to generate packet IDs
2019-02-28 11:17:27 +08:00
67376727c9
Add batch send support for emqx_client:publish/2
...
also cover emqx_portal_mqtt with CT
2019-02-28 11:17:27 +08:00
fbe67e6784
Introduce new bridge impl
2019-02-28 11:17:27 +08:00
c3e6f3c3b2
Improve try catch syntax ( #2263 )
...
* Replace case catch.. with try ... catch
Prior to this change, case catch ... would cost a lot of performance
because it would retrieve the whole stacktrace. However, try...catch
will not retrieve the whole stacktrace. So try...catch syntax is better.
2019-02-28 09:54:28 +08:00
269b74232a
Introduce some common types
2019-02-19 17:16:11 +08:00
44d3eff094
Auto-pull-request-by-2019-02-19 ( #2232 )
...
* Update Copyright to 2019 (#2191 )
* Disable bridges by default (#2189 )
* Fix warning logger args emqx#2195
* Ambiguity elimination (#2217 )
* Fix emqx_ws_connection: prevent crashes on pong (#2210 )
* Issue#2184 (#2194 )
* Delete dep-vsn-check
* Format app.src
2019-02-19 14:00:34 +08:00
31e95b56c4
Update Copyright to 2019
2019-01-29 10:43:25 +08:00
d7254cdc7f
Add more macros for logger
2019-01-04 17:30:27 +08:00
3b8eb41347
Remove the log header macro
2019-01-04 17:30:27 +08:00
eeb0cab3e3
Update proc meta-data for empty clientid ( #1980 )
2018-11-23 18:11:46 +08:00
bc1464a33f
Lazy logging without header
2018-11-19 11:17:58 +08:00
82b8047349
Helper funcs for adding proc meta-data
2018-11-19 11:17:58 +08:00
e8cc65ef40
Change logger micros
2018-11-19 11:17:58 +08:00
41315bff0d
Log macros for lazy evaluation
2018-11-19 11:17:58 +08:00
32d3826440
Replace macro QOS$i to QOS_$I
...
The two styles of qos macro name in one project is chaotic. It is not
a good practice.
So I change the QOS$i to QOS_$i
2018-11-08 20:42:31 +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
b10f49b52c
Add CONNACK macros for MQTT V3.1.1
2018-08-25 11:49:19 +08:00
0f052ce352
Upgrade connection, protocol and session modules for MQTT 5.0
2018-08-24 18:39:59 +08:00
6ab489a9b5
Change the MAX_CLIENTID_LEN to 65535
2018-08-10 15:38:08 +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
bffdd2ba74
Upgrade esockd and add more test cases
2018-05-22 13:01:19 +08:00
31bc091873
Implement MQTT Version 5.0 client
2018-05-06 17:45:18 +08:00
dc7804a2dc
Support MQTT Version 5.0 Client
2018-04-30 12:27:39 +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
a3e97f798b
Update Copyright to 2018
2018-01-16 08:57:46 +08:00
a904dfd4f2
Comment the ERTS_MINIMUM macro
2017-12-07 16:26:32 +08:00
a42fcb2c39
Fix conflicts
2017-12-05 16:34:18 +08:00
26fb809dbe
Fix issue#1293 - the retained flags should be propagated for bridge.
2017-11-29 14:09:46 +08:00
2cec86eba7
Merge with version 2.3.0
2017-11-21 14:14:12 +08:00
d41fd94abb
Format the 'trie_node' record
2017-11-17 20:55:57 +08:00
4b8cd18f5d
Merge with EMQ X project
2017-10-09 19:43:06 +08:00
d3f52898ee
Add Hot configuration plugin
2017-09-05 16:52:07 +08:00
9e6c63b91b
REST API add modify_config/config_list
2017-08-17 15:51:20 +08:00
7c1ee6610d
Add http management APIs
2017-08-09 10:14:29 +08:00
66c3c26d8b
Support 'mountpoint'
2017-03-23 15:04:37 +08:00
0df59934c7
Fix the GPROC_POOL macro
2017-03-13 12:14:57 +08:00
bb91bc04c6
Merge pull request #941 from callbay/issue#935
...
Fix Issue#935
2017-03-13 11:41:22 +08:00
7cb3b7ca8a
Id -> I
2017-03-12 23:07:45 +08:00
35e08df735
Change the default QoS of will message to QOS_1
2017-03-06 18:17:07 +08:00
c3919a64e6
Format 'trie_node' record
2017-03-06 18:13:07 +08:00
98e15ebbf4
Prepare for MQTT/5.0
2017-03-06 18:11:09 +08:00
9309baf17c
Rename mqtt_msgid() type to mqtt_msg_id()
2017-02-23 22:59:26 +08:00
Shawn