7aff861f9b
refactor(emqx_modules): Move emqx_modules to lib-opensource
...
emqx_moduels for enterprise is refactored as a lib/plugin
in order to avoid merge conflicts, we make sure they can
co-exist in the same branch, because lib-opensource is compiled
in opensource project and lib-enterprise (to be added) is
compiled in enterprise project
2021-02-08 21:35:44 +01:00
6c1129dc6a
Auto-pull-request-on-2021-01-29 ( #4114 )
...
* fix(share sub): fix the issue that the number of subscriptions dropped to 0 during the picking subscriber and caused a crash
* Connection Busy Alarms (#3992 )
feat(emqx_connection): improve port_busy alarm
* fix(emqx_connection): tune the congestion alarm params
* chore(deps): upgrade esockd to 5.7.5
* fix(appup): correct the appup file
2021-01-30 10:30:18 +08:00
d78b2b23c1
chore(build): update pkg version
2021-01-29 19:29:41 +08:00
5878950dc3
feat(websocket): support for checking subprotocols ( #4099 )
2021-01-28 20:42:57 +08:00
02cb8d0211
chore(style): set warnings_as_errors compile option
2021-01-27 18:02:12 +08:00
de972b3d84
fix(emqx_vm): Call recon_alloc:allocators/0 to get allocators
2021-01-23 11:42:28 +01:00
23b2f4fa72
Merge pull request #4050 from zmstone/chore-delete-stale-code
...
chore(emqx_vm): delete stale code
2021-01-23 11:13:22 +01:00
7c3cd26589
chore(elvis): fix elvis wanrings
2021-01-23 18:07:58 +08:00
f59377adf5
fix(logs): print the correct username and clientid
2021-01-23 18:07:58 +08:00
33c35915ca
refactor(emqx_vm): make elvis happy
2021-01-22 09:23:20 +01:00
4680ba574c
chore(emqx_vm): Delete get_ets_object, not used
2021-01-22 09:21:45 +01:00
47df29ae49
chore(emqx_vm): delete stale code
...
The port binary format is no longer compatible in OTP 23
2021-01-22 07:50:00 +01:00
0087303b25
feat(shared_sub): Support hashing from source topic.
2021-01-21 21:05:56 +01:00
5aa63ed203
fix(shared_sub): align default value and default config
...
Shared subscription default dispatch strategy is 'random' in config
but 'round_robin' in code. This commit is to make sure they are the
same: both are 'random'.
2021-01-21 21:05:56 +01:00
598207e308
fix(ws_connection): proplists:get_bool for boolean flags
2021-01-15 14:28:22 +01:00
5794a708ed
feat(emqx_ws_connection): Prevent EMQX from CSWSH Cross-Site Web-Socket Hijack
2021-01-15 14:28:22 +01:00
32b23b9181
Revert "feat(auth_http): support for getting websocket cookies"
...
This reverts commit 5427057c2c
2021-01-14 15:10:48 +01:00
d437f9f228
chore(elvis): fix elvis warnings
2021-01-14 15:46:16 +08:00
f2190dd5b5
chore(mnesia): explicitly specify the copy type for table
2021-01-14 15:46:16 +08:00
76fc6225d3
fix(elvis): fix elvis checking
2021-01-14 15:46:16 +08:00
2a029b71c9
perf(mnesia): unify the copy types of all nodes
2021-01-14 15:46:16 +08:00
5427057c2c
feat(auth_http): support for getting websocket cookies
...
see: https://github.com/emqx/emqx-auth-http/pull/225
2021-01-11 09:21:16 +08:00
2b481dabe7
Fix some dialyzer warnings ( #3988 )
2021-01-05 20:49:50 +01:00
b9bb88d9eb
fix(emqx): fix dialyzer warnings
2021-01-04 14:14:55 +01:00
fbf8d3e111
fix(share sub): fix the issue that the number of subscriptions dropped to 0 during the picking subscriber and caused a crash
2020-12-31 14:03:55 +08:00
4f82c77e7a
fix(log): improve the error log message on hook failure ( #3973 )
2020-12-31 13:55:09 +08:00
ac0f51fec3
fix(max topic len): use the maximum length limit by default
2020-12-28 14:48:32 +08:00
739e49218f
fix(cm): fix the problem of registering a channel twice ( #3831 )
2020-12-28 11:03:29 +08:00
b68a0b3730
fix(emqx_lua_hook): fix dialyzer warnings.
2020-12-25 07:42:01 +08:00
7bdd093ef5
Merge remote-tracking branch 'origin/dev/v4.3.0' into umbrella-fix-build
2020-12-11 08:55:57 +01:00
6973837829
fix(emqx_plugins): Dialyzer warnings
2020-12-10 23:34:36 +01:00
56d7b3deb1
Umbrella fix build ( #8 )
2020-12-10 11:25:25 +01:00
59d69b730b
fix(emqx_logger): Dialyzer warnings
2020-12-10 11:22:38 +01:00
b9b20ba268
fix(emqx.erl): Dialyzer warnings
2020-12-10 11:22:38 +01:00
62e0a21ad0
fix(emqx_auth_sys, emqx_ws_connection): Dialyzer warnings
2020-12-10 11:22:38 +01:00
18ae158f45
fix(emqx_plugins, emqx_sys, emqx_sys_mon, emqx_ws_connection): Dialyzer warnings
2020-12-10 11:22:38 +01:00
baaa4e847d
fix(emqx_sn_gateway): Dialyzer warnings
2020-12-10 09:49:24 +01:00
eecd2b5f35
fix(emqx_types): Non mandatory map fields
2020-12-10 09:38:07 +01:00
adc9cc30f6
refactor(emqx_modules): Swallow errors when write modules
2020-12-10 09:35:36 +01:00
d47a2294ca
fix(emqx_mod_topic_metrics): Dialyzer warnings
2020-12-10 09:35:36 +01:00
0f0ca1e9fd
fix(emqx_mod_rewrite): Dialyzer warnings
2020-12-10 09:35:36 +01:00
ab5599b3ec
refactor(hook): Add emqx_hooks:put to hide already_exists error
...
This also fixes dialyzer warnings in emqx_mod_presence
2020-12-10 09:35:36 +01:00
5793ef6640
fix(emqx_mod_sup): Dialyzer warning
...
All the callers of start_child API are discarding the return value.
2020-12-10 09:35:36 +01:00
f3d973689b
fix(emqx_listeners): Dialyzer warnings
2020-12-10 09:35:36 +01:00
7a39470200
fix(emqx_connection): Dialyzer warnings
2020-12-10 09:35:36 +01:00
7dd67a6caf
fix(emqx_channel): Dialyzer warning
2020-12-10 09:35:36 +01:00
cfe52cbb8d
fix(emqx_broker): Dialyzer warning
2020-12-10 09:35:36 +01:00
0eb697fa6f
fix(emqx_app): Dialyzer warnings
2020-12-10 09:35:35 +01:00
3fb69cc407
fix(emqx_alarm): Dialyzer warnings
2020-12-10 09:35:35 +01:00
0d90d5c66b
fix(emqx_acl_cache): Dialyzer warnings
2020-12-10 09:35:35 +01:00
d4aa5ebf55
fix(emqx): Fix dialyzer warnings
2020-12-10 09:35:35 +01:00
7f556d36d1
Merge branch 'dev/v4.3.0' into e422_to_v430
2020-12-09 11:28:36 +08:00
6d1cd6b7ea
refactor(emqx_password): move the module to emqx application
...
Future plugins will require emqx as a dependency.
This commit also brings back bcrypt to the system which was temporary
removed when converting to umbrella project
2020-12-08 22:09:59 +01:00
0ee489a9be
fix(congestion): change the conn congestion alarm msg body
2020-12-07 15:05:20 +08:00
d00ea48752
feature(tcp): alarm when tcp connection congested
2020-12-07 14:35:38 +08:00
505257b25b
chore(appup): remeove the code_change codes
2020-12-05 17:22:44 +08:00
ae9449a004
chore: eliminate diaylzer warnings
2020-12-05 17:20:50 +08:00
f1b3bbd7bc
chore: supply the code_change logic
2020-12-05 17:20:50 +08:00
3b1074d11f
refactor(conn): not saving anonymous func
2020-12-05 17:11:58 +08:00
3f924631e4
refactor(limiter): not saving anonymous function
2020-12-05 17:03:57 +08:00
2e7ec25ae2
chore(appup): suspend esockd_acceptor
2020-12-05 15:04:14 +08:00
73d02beace
refactor(apps): Merge emqx_libs back to emqx
...
And move emqx app back to root level
After realising the challenges of developing plugins in standalone
rebar projects. it is perhaps more smooth to keep using emqx as
a rebar dependency
2020-12-04 19:58:58 +01:00
7462ed92ba
chore: eliminate diaylzer warnings
2020-12-04 22:33:29 +08:00
ca0f6b69a4
chore: supply the code_change logic
2020-12-04 22:33:29 +08:00
80c503fd64
refactor(conn): not saving anonymous func
2020-12-04 22:33:29 +08:00
40d272815a
refactor(limiter): not saving anonymous function
2020-12-04 22:33:29 +08:00
f5162562a4
chore(appup): update appup
2020-11-26 10:42:35 +08:00
aa7124f3c9
chore(appup): use binding var 'VSN'
2020-11-25 14:40:25 +08:00
3ca39cb9cb
chore(appup): update version
2020-11-25 10:27:56 +08:00
3f41adc3bd
chore(appup): update version
2020-11-25 01:07:19 +08:00
cf7c3b4f0c
fix(appup): fix syntax error
2020-11-13 17:40:36 +08:00
253c43e405
feat(emqx_metrics): add new functions to count message received
2020-11-13 16:42:48 +08:00
41a8f2f811
Merge branch 'stable/e4.2.0' of https://github.com/emqx/emqx into stable/e4.2.0
2020-11-13 10:40:28 +08:00
77d777fd11
chore(acl): rollback emqx_access_rule module
2020-11-13 10:40:14 +08:00
8cc69e639f
fix(congestion): change the conn congestion alarm msg body
2020-11-11 17:33:38 +08:00
26c03aaa43
feat(connection): update alarm info
2020-11-11 09:37:39 +08:00
e100b0a5e9
feat(emqx_metrics): add new functions to count message received
2020-11-10 23:36:11 +08:00
cc69225b6d
feature(tcp): alarm when tcp connection congested ( #3818 )
2020-11-10 23:36:11 +08:00
139306b61c
fix(json): fix decoding/encoding empty object error
2020-11-10 23:36:11 +08:00
b883e238bf
fix(ws): take ws_cookie to clientinfo
...
see: https://github.com/emqx/emqx/issues/3747#issuecomment-702268570
2020-11-10 23:36:11 +08:00
5a8efd9d20
feature(project): move src to apps/emqx/src
2020-10-31 09:19:28 +08:00
b373c0cf1b
fix(json): fix decoding/encoding empty object error
2020-10-24 15:49:15 +08:00
8462da9652
fix(topic metrics): add appup.src
2020-10-24 11:21:39 +08:00
b927bb7af6
fix(topic metrics): calculate the rate correctly
2020-10-24 11:21:39 +08:00
2feeb4d91f
fix(ws): take ws_cookie to clientinfo
...
see: https://github.com/emqx/emqx/issues/3747#issuecomment-702268570
2020-10-24 11:21:39 +08:00
87ef4e4dd9
chore(types): Add the disconnected_at field definition in conninfo ( #3764 )
2020-10-24 11:21:39 +08:00
eb4b9936dc
fix(modules): fix conflicts
2020-10-11 11:12:39 +08:00
7b98f62f7a
fix(config): enable force_shutdown_policy by default
2020-09-30 11:36:30 +08:00
da4d71917f
fix(ignore-loop-deliver): fix issue#3738 ( #3741 )
2020-09-29 15:35:16 +08:00
76ec65830c
fix: fix session_locking_strategy enum typos
2020-09-29 15:35:16 +08:00
fa31062a5e
chore(topic rewrite): export more functions
2020-09-11 12:37:47 +08:00
3d4eac7e7a
fix(json): fix safe_encode for utf8 string
2020-09-11 12:26:13 +08:00
edcbdcce87
improve: module_acl_internal load/unload api ( #3706 )
2020-09-05 17:23:22 +08:00
90b33b044d
feature(ratelimit): support to set ratelimit & quota policy
2020-09-05 17:23:22 +08:00
4233ef4e85
fix(xref): correct the type spec of logger_handler_info()
2020-08-28 17:10:26 +08:00
9985e2675c
fix(logger): resolve issues when starting and stopping log handlers
2020-08-28 17:10:26 +08:00
faf0b5289c
feature(logger): support starting and stopping log handlers
2020-08-28 17:10:26 +08:00
e411b4bad3
fix(cm): fix never matching clause
2020-08-28 17:10:26 +08:00
261bd66a3d
refactor(alarm): refactor resource down alarm
2020-08-22 15:27:11 +08:00
7a2a01a4de
fix(mqtt piggyback): bad data type
2020-08-22 15:27:11 +08:00
ec12acc4ef
feature(mqtt piggyback): transporting mutli MQTT packets at once or single
2020-08-22 15:27:11 +08:00
cfcbc53a8b
refactor(alarm): remove excess case
2020-08-22 15:27:11 +08:00
c2cc8ab218
feature(resource-down-alarm): add resource down alarm
2020-08-22 15:27:11 +08:00
901573c6a5
fix(topic-metrics): fix the issue that the corresponding data is not properly cleaned up when unregistering ( #3679 )
2020-08-22 15:27:11 +08:00
f47e10e08a
feature(emqx_mod_rewrite): separate rewrite rules for pub and sub ( #3676 )
2020-08-22 15:27:11 +08:00
dbeabf3de0
refactor(telemetry): remove telemetry code from emqx core
2020-08-22 15:27:11 +08:00
9e5e6f2e98
fix(guid): compatible with OTP 23
2020-08-22 15:27:11 +08:00
a76be8e0fa
chore: fix the compilation error when there is "/" in the branch name
2020-08-22 15:27:11 +08:00
e37a70509b
feature(telemetry): support for collecting telemetry data and disable it by default ( #3653 )
2020-08-14 16:58:08 +08:00
98faa698f3
feature(quota): add quota confs to limit the number of message forwards
2020-08-14 16:58:08 +08:00
89377aeaa2
improve(type): refine the message header types
2020-08-14 16:58:08 +08:00
87780c1c1b
fix(static-cluster): fix the issue that static cluster failure caused by the wrong way of creating tables
2020-08-14 16:58:08 +08:00
aaf29ee164
fix(alarm): fix the issue that memory watermark were not set correctly
2020-07-31 18:07:20 +08:00
1ba4743213
refactor(alarm): new data structure and support regular cleaning of deactivated alarms
2020-07-31 18:07:20 +08:00
5676026e2a
fix(alarm): missing partition alarm
2020-07-31 18:07:20 +08:00
43b49edd28
feature(alarm): new design for alarm
2020-07-31 18:07:20 +08:00
0817761aee
fix(emqx_channel): EMQ X replaces MQTT properties when node connects using "topic-alias-maximum" property
2020-07-31 18:07:20 +08:00
00bc525d8e
refactor(add-log): log when subscription fails
2020-07-31 18:07:20 +08:00
83a2af812f
feat(ratelimit): refactor ratelimit
2020-07-31 18:07:20 +08:00
961e7b9818
chore: update app.src.script
2020-07-20 10:08:47 +08:00
492d224728
Auto-pull-request-on-2020-07-17 ( #3600 )
...
* refactor(channel): skip the ACL checking for inner subscribe
* fix(props): fix the prop_emqx_sys results of judgment
* Update esockd to 5.7.1
* test(topic-metrics): add test cases for topic metrics
* perf(emqx_vm): make emqx_vm:get_memory/0 more efficiency
2020-07-17 18:25:46 +08:00
211c800e24
fix(properties): downlink will msg contains non-publish properties
...
The paho test failed because the client received a will message
that has an `Will-Delay-Interval` property.
All the 7 allowed PUBLISH properties are listed as follows:
```
'Payload-Format-Indicator',
'Message-Expiry-Interval',
'Response-Topic',
'Correlation-Data',
'User-Property',
'Subscription-Identifier',
'Content-Type'
```
2020-06-21 11:27:22 +08:00
600b1055f3
fix(json): convert a proplists to ejson instead of map
2020-06-20 15:42:07 +08:00
1b6a586948
feature(mqtt): support response information ( #3533 )
2020-06-20 15:07:37 +08:00
8707afa54c
fix(enhanced_auth): fix bug when "conn_props = undefined"
2020-06-20 14:29:20 +08:00
9a8859a44c
refactor(topic): move triples/1 func into emqx_trie module
2020-06-18 17:38:34 +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
ea2a424ce2
Add ensure/2 funcs to avoid needless logs ( #3483 )
2020-06-04 10:46:53 +08:00
f456f40c59
Subscribe or unsubscribe via HTTP API skip ACL checking
2020-06-04 10:45:58 +08:00
42fc81338c
Fix(modules): correct the bad return value for emqx_modules:load/0
2020-06-04 10:38:28 +08:00
3fb82f7234
Fix(connect): fix the race condition for openning session
...
- Remove the register_channel/1,2 functions
2020-06-02 17:21:06 +08:00
59f95f8421
Helpful message when no commands available
2020-05-23 09:41:25 +08:00
83b1f3e6c8
Fix unexpected packet before connected
2020-05-22 18:18:52 +08:00
18ae15ef9a
Fix typos
2020-05-21 17:51:22 +08:00
1f07700930
Print helpful messages when no commands available
2020-05-16 08:48:05 +08:00
80e2bd19b9
Fix case_clause in issue#3455
2020-05-12 10:39:22 +08:00
48d6acdb25
Replace peercert with cn/dn feilds in ClientInfo
2020-04-30 16:35:15 +08:00
c35a40a6b6
Fix some error for reauthentication
2020-04-28 11:48:07 +08:00
7ba801c8d4
Fix reload acl module and clean acl caches ( #3409 )
2020-04-26 15:45:55 +08:00
7cf97acddd
Delete expiried client
2020-04-26 15:38:29 +08:00
021520315a
Update enhanced auth hooks
2020-04-24 10:21:22 +08:00
b37c61fdb5
Merge pull request #3392 from emqx/print
...
Optimize cli print
2020-04-17 18:05:37 +08:00
5922f5358e
Merge pull request #3396 from emqx/add_hook_to_auth_packet
...
Add hook to auth packet
2020-04-17 18:05:25 +08:00
6cab60b6ab
Export emqx_modules:find_module/1
2020-04-17 11:02:40 +08:00
dccf3560f0
Add hook to auth packet
2020-04-16 16:07:01 +08:00
fb661b1d92
Support return all registered topics
2020-04-16 10:35:35 +08:00
eebc5e4b0a
Optimize cli print
2020-04-15 18:05:30 +08:00
e806a96031
Change timestamps to millisecond
2020-04-15 09:03:52 +08:00
9ba938b9d9
EMQX failed to start when the listening port was occupied ( #3354 )
2020-04-11 10:18:35 +08:00
d49f4118fe
Mgmt emqx modules ( #3376 )
2020-04-10 19:55:21 +08:00
d4932533ca
Auth packet ( #3374 )
2020-04-10 19:45:18 +08:00
1790cde942
Get client's addr/port from proxy header if enable proxy_protocol
2020-04-10 19:40:10 +08:00
49440bd2e3
Export functions
2020-03-27 18:22:59 +08:00
edb42b1b0f
Set topic alias on v5 only
2020-03-27 17:02:38 +08:00
792a14aaf7
Fix plugin test case
2020-03-27 15:31:11 +08:00
55a8b1b173
Support topic metrics ( #3341 )
...
Support topic metrics
2020-03-27 13:33:10 +08:00
78144c0ca5
Update error log ( #3342 )
...
Optimize content of error log
2020-03-27 10:10:23 +08:00
5eadca1782
Merge pull request #3335 from emqx/reload_plugin
...
Read new configuration items when plugins is loaded
2020-03-26 18:35:49 +08:00
5c5267c96b
Merge pull request #3327 from emqx/fix_json_encode
...
Fix emqx_json encode return types error
2020-03-26 18:33:16 +08:00
9e6966110d
Move emqx_delay_publish here ( #3323 )
...
Move emqx_delay_publish here
2020-03-26 18:32:24 +08:00
9398865741
Fix the issue that configuration was not loaded when plugin started
2020-03-25 10:30:08 +08:00
59adb9a652
Supports broker-to-client topic aliases ( #3325 )
2020-03-24 15:23:01 +08:00
2ab6ec418e
Add subscription option for proxy subscribing
2020-03-24 11:31:25 +08:00
3b537760d5
Read new configuration items when plugins is loaded
2020-03-23 15:23:38 +08:00
95baee8c8e
Fix emqx_json encode return types error
2020-03-21 13:38:48 +08:00
7e00b58db5
Remove the CONNACK's `Maximum-QoS` key if it equal to 2 ( #3321 )
2020-03-17 17:56:34 +08:00
b2e5b523dd
Change global_gc to major mode ( #3317 )
2020-03-17 14:28:58 +08:00
1221b8eb00
Force utf8 json encoding by default #3287
2020-03-11 11:18:12 +08:00
47720b906f
Fix `peer_cert_as_username` option not working
...
see #3281
2020-03-05 15:55:39 +08:00
ad7cbb4428
Fix einval after socket was closed
2020-03-05 14:28:12 +08:00
caed16f57b
Fix `acl_deny_action`
2020-03-05 14:27:41 +08:00
6b5a8949c5
Change rate limit pausing logs to warning
2020-03-02 18:26:37 +08:00
9b6a8ebe84
Fix emqx_json:to_ejson
2020-02-21 13:17:12 +08:00
3f6f0eca40
Add an option to allow client bypass auth plugins
2020-02-21 09:42:26 +08:00
f6b0ad8873
Ignore some discarded exceptions
2020-02-17 09:40:44 +08:00
f29a8b0d5c
Mqtt protocol tests ( #3237 )
...
Add more test cases for MQTT
2020-02-07 10:07:36 +08:00
839465fbd8
Enhance security
2020-02-07 09:19:21 +08:00
b9bdb03005
Decode/Encode json from nested proplist
2020-02-06 12:00:18 +08:00
368b85027e
Fix issue#3228
2020-02-04 16:30:38 +08:00
3c459e8e74
Compatible jsx encode/decode ( #3230 )
2020-02-04 16:18:19 +08:00
367398e965
Remove jsx from app.src
2020-01-19 19:41:13 +08:00
eea377eb8f
Replace 'jsx' with 'jiffy' and add more test cases
2020-01-19 16:58:51 +08:00
b3e2cc5a18
Replace 'jsx' with 'jiffy' to optimize json encode/decode
2020-01-19 16:58:51 +08:00
e17241884c
Send DISCONNECT packet for mqttv5 ( #3183 ) ( #3208 )
2020-01-17 19:48:39 +08:00
f4081b5885
Tune the global GC
2020-01-17 18:32:00 +08:00
7a2234c608
Improve emqx_mqtt_caps:get_caps/1 ( #3198 )
2020-01-17 16:29:46 +08:00
8734922abb
Fix rap handling and keep the value of retain flag in bridge mode ( #3189 )
2020-01-17 11:37:28 +08:00
2897e4fa06
Fix the bug that cannot add a second MQTT-WS TCP Port ( #3196 )
2020-01-17 10:08:34 +08:00
a318532bb0
Tuning the 'force_gc_policy' of MQTT connections ( #3192 )
...
Tuning the 'force_gc_policy' of MQTT connections
2020-01-17 09:42:16 +08:00
2b3003b323
Move the global GC server from 'emqx-recon' to 'emqx' project ( #3190 )
2020-01-16 23:45:17 +08:00
f6b2c9a69f
Correct timestamp for banned ( #3188 )
2020-01-16 23:11:19 +08:00
2ba624ac31
Add 'compose/1', 'compose/2' functions
2020-01-13 21:00:40 +08:00
fdeade3212
Add more test cases
2020-01-09 20:01:46 +08:00
b1a22931f4
Add testcase for takeover ( #3160 )
2020-01-09 12:26:24 +08:00
7d3a08dc13
Improve 'client.connect', 'client.connack' hooks ( #3153 )
2020-01-04 10:44:17 +08:00
6b8ffc386a
Fix WS reason code ( #3149 )
2020-01-04 10:06:50 +08:00
7ea75f4289
Update copyright
2020-01-03 18:31:08 +08:00
f33217c049
Fix unexpected timeout
2019-12-31 09:06:58 +08:00
597558fee8
Fix unexpected timeout
2019-12-30 21:27:47 +08:00
46ca3f2f82
Add metrics for session's lifecircle
...
- session.created
- session.resumed
- session.takeovered
- session.discarded
- session.terminated
2019-12-30 09:29:41 +08:00
12c6d5fe2c
Add more metrics for client's lifecircle
...
- client.connect
- client.connack
- client.connected
- client.authenticate
- client.check_acl
- client.subscribe
- client.unsubscribe
- client.disconnected
2019-12-30 09:28:55 +08:00
9a3d16c654
Add 'emqx_packet:info/2' function and test cases
2019-12-30 09:28:38 +08:00
b7ca3905a6
Breaking Change: Add new hooks for client and session lifecircle ( #3138 )
2019-12-27 16:31:06 +08:00
d000284a40
Merge branch 'caps' into develop
2019-12-21 16:04:41 +08:00
b612674ffa
Update emqx_mqtt_caps.erl
2019-12-21 14:16:37 +08:00
b3eed9123f
Fix typo
2019-12-21 10:39:02 +08:00
578355442b
Add more metrics and improve the 'channel', 'session' modules ( #3128 )
2019-12-20 21:47:32 +08:00
2cf3af12ef
Update test cases for emqx_connection ( #3116 )
2019-12-20 19:15:45 +08:00
116c593178
Fix returned value of plugin reloading ( #3126 )
2019-12-20 16:34:07 +08:00
9b9df46718
Add sockport to ClientInfo ( #3122 )
2019-12-19 13:34:24 +08:00
70ae3c75a0
Remove emqx_time module
2019-12-17 09:38:33 +08:00
eea5e14b0c
Fix event/message out of order
2019-12-16 22:12:56 +08:00
814f103e34
Fix issue#3109 - remove the 'sessions.persistent.count', 'sessions.persistent.max' stats
2019-12-16 16:41:42 +08:00
1f25f4439f
Remove the 'stop_reason' field
2019-12-16 12:45:46 +08:00
635c3f75fe
Improve the 'emqx_connection' module for CT
2019-12-16 11:25:47 +08:00
ad9e0fc311
Support the 'clean_start = false' websocket connection
2019-12-16 11:25:47 +08:00
2ef52828bc
Improve 'emqx_connection' module and update test cases
2019-12-16 11:25:47 +08:00
7ac60678de
Add test cases for emqx_cm and emqx_router_helper modules
2019-12-13 18:09:48 +08:00
c5c99b7c4e
Improve 'emqx_ws_connection' module and add more test cases
2019-12-13 18:07:59 +08:00
2a3baed7e0
Merge pull request #3103 from emqx/ws-conn-ct
...
Rename 'channel.gc.cnt' to 'channel.gc'
2019-12-13 18:04:54 +08:00
d193b5fa0d
Rename 'channel.gc.cnt' to 'channel.gc'
2019-12-11 20:39:51 +08:00
d1c3dec730
Optimize emqx_session and add more test cases
2019-12-11 13:44:52 +08:00
e30c0ac31d
Change log level for existing metric
2019-12-10 17:20:21 +08:00
ec2f758c9f
Use erlang:system_time/1
2019-12-10 09:25:39 +08:00
08e234f61e
Fix typo
2019-12-10 09:24:33 +08:00
0f9f1258b6
Improve the emqx_message module and add more test cases
...
- Add 'emqx_message:clean_dup/1' function
- Clean dup flag before publishing a message
- Add more test cases for emqx_message module
2019-12-10 09:22:38 +08:00
cd94ba71b4
Remove the 'try' ... 'catch'
2019-12-10 09:01:55 +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
dace882667
Fix will message
2019-12-07 17:06:22 +08:00
dc3e7dc21c
Ignore the expired messages
2019-12-07 16:51:20 +08:00
bbcd2bffc5
Improve the session module ( #3082 )
...
Improve the session module
2019-12-07 15:54:02 +08:00
32500685a1
Export emqx_cm:kick_session/2
2019-12-07 13:35:55 +08:00
5b949fda2c
Add emqx_cm:kick_session/1
2019-12-07 13:31:33 +08:00
9c3273a2c6
Improve the process of handling MQTT control packets ( #3079 )
2019-12-06 19:51:06 +08:00
98b109b6b2
Merge pull request #3074 from emqx/emqx_desc
...
Add emqx.app.src.script
2019-12-05 18:01:24 +08:00
dceb087039
Format code
2019-12-04 13:54:59 +08:00
4b59db62fa
Optimize caps
2019-12-04 13:52:01 +08:00
691c6aa182
Add emqx.app.src.script
2019-12-04 13:50:31 +08:00
a540958846
Add mqtt.strict_mode configuration ( #3069 )
...
Add mqtt.strict_mode configuration
2019-12-04 10:54:52 +08:00
8bf06b9c63
Fix typo
2019-11-23 10:53:27 +08:00
f44b8ce607
Avoid emqx crashes due to auth plugins ( #3047 )
...
Avoid emqx crashes due to auth plugins
2019-11-23 10:11:48 +08:00
790c729b1f
Optimize code
2019-11-21 16:26:50 +08:00
d7ddc406fa
Fix ConnInfo of client.connected hook
2019-11-21 15:01:57 +08:00
1af1fc4f6a
Fix the check of limiter
2019-11-18 11:51:58 +08:00
39dbb03629
Fix the 'undefined function' call
2019-11-18 11:11:20 +08:00
c9963b1df5
Replace esockd_net with inet
2019-11-18 10:58:15 +08:00
6288cd1345
Merge branch 'develop' into bump-version
2019-11-18 10:53:33 +08:00
d793c4256f
Merge pull request #3034 from emqx/rm-vm-module
...
Improve the emqx_vm module and update test cases
2019-11-18 10:51:54 +08:00
b10cd85ba3
Merge pull request #3033 from emqx/flapping2
...
Optimize flapping and banned modules
2019-11-18 10:50:35 +08:00
Zaiming Shi