Commit Graph

1548 Commits

Author SHA1 Message Date
JianBo He 2a029b71c9 perf(mnesia): unify the copy types of all nodes 2021-01-14 15:46:16 +08:00
tigercl 372687d79d
improve(http): replace httpc with gun, improve performance and fix httpc unresponsiveness (#3940) 2021-01-13 13:47:23 +08:00
JianBo He 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
Ayodele 2b481dabe7
Fix some dialyzer warnings (#3988) 2021-01-05 20:49:50 +01:00
zhanghongtong ca1e78677e chore(dashboard): delete static files
delete static files of dashboard and download them during build
2021-01-05 17:22:19 +08:00
Zaiming Shi b9661cddfa
fix(emqx_lwm2m_message): Path is built from binary format (#3987) 2021-01-04 17:31:21 +01:00
ayodele.akingbule 9b6b762f1c fix(emqx_retainer): fix dialyzer warnings 2021-01-04 14:14:55 +01:00
ayodele.akingbule 30588ac666 fix(emqx_mgmt): fix dialyzer warnings 2021-01-04 14:14:55 +01:00
ayodele.akingbule 990be9c198 fix(emqx_rule_engine_api): fix dialyzer warnings 2021-01-04 14:14:55 +01:00
Shawn e518828d8f
fix(rule_engine): mechanism of restarting resources (#3980) 2021-01-04 11:52:57 +08:00
Ayodele 26021b37b3
Umbrella fix build (#3969)
* fix(dialyzer): dialyzer warning.
2021-01-04 09:10:22 +08:00
Shawn d86b5ef210 fix(rule_engine): compile warnings on the macro RAISE 2020-12-31 17:03:39 +08:00
Shawn a747cf16bd
fix(resource_cli): update the CLIs for resources (#3978) 2020-12-31 13:41:33 +08:00
bignullnull 37974f7376
fix(rule_engine): add resource reconnect check (#3974)
* fix(rule_engine): add resource reconnect check
* fix(rule_engine): add reason for RAISE macro
2020-12-31 12:51:01 +08:00
wwhai 903ce29ce0 fix(rule_engine): fix resource update maybe failure 2020-12-31 11:43:03 +08:00
zhanghongtong 41afcde964 chore(ssl conf): update the ssl configuration format for mongo, pgsql, and redis plug-ins 2020-12-29 00:03:12 +08:00
zhanghongtong 6989c7a83d test(CI): add cts 2020-12-29 00:03:12 +08:00
bignullnull efb32e9903
test(rule_engine): add update resource unit test case (#3964)
* test(rule_engine): add update resource unit test case

* feat(rule_engine): add update resource support

Co-authored-by: wwhai <cnwwhai@gmail.com>
2020-12-28 14:59:28 +08:00
Yudai Kiyofuji 56920b6ca6
fix(bridge_mqtt): max_inflight_size -> max_inflight; this enables emqtt.erl to use the value (#3938)
* fix(bridge_mqtt): max_inflight_size -> max_inflight; this enables emqtt.erl to use the value

* chore(bridge_mqtt): fix elvis

* fix(worker): max_inflight_batches -> max_inflight
2020-12-28 13:43:13 +08:00
JianBo He 739e49218f
fix(cm): fix the problem of registering a channel twice (#3831) 2020-12-28 11:03:29 +08:00
JianBo He 9e22f492c7 refactor(rule-engine): add proc_sql_param_str/2 to handle sql params 2020-12-28 10:51:13 +08:00
JianBo He d628c49f16 fix(management): make client format function durable 2020-12-28 10:51:13 +08:00
ayodele.akingbule b68a0b3730 fix(emqx_lua_hook): fix dialyzer warnings. 2020-12-25 07:42:01 +08:00
ayodele.akingbule 2126129aee fix(emqx_prometheus): fix Dialyzer warnings 2020-12-25 07:42:01 +08:00
ayodele.akingbule 80cca940c2 fix(emqx_http_client): fix Dialyzer warnings 2020-12-25 07:42:01 +08:00
Shawn 02245aeb7a chore(test): provisionally delete the testcase for SASL
The SASL feature in emqtt is not ready, delete the testcases for now.
2020-12-23 16:42:49 +08:00
Shawn 865c63d82e fix(emqx_mgmt): data export failed on generating the exported filename 2020-12-23 16:41:18 +08:00
Shawn 6b5878cdd0 fix(test): solve verification issue when verify the resource numbers 2020-12-23 16:39:40 +08:00
Shawn ec8cfecdc0 fix(test): typos in emqx_mgmt_api_SUITE 2020-12-23 13:47:22 +08:00
Shawn 60f1b64ad9 fix(test): delete extra emqx_lua_hook:stop() 2020-12-22 22:05:24 +08:00
Shawn 9e3b6da9ca fix(test): delete extra verfication for 'max_age' 2020-12-22 18:22:17 +08:00
Shawn 54ff20ec0e fix(build): remove the extra cowlib deps from emqx_auth_http 2020-12-22 17:50:10 +08:00
zhanghongtong a364758e2a test(emqx_recon): stop emqx correctly in the test case 2020-12-22 13:39:49 +08:00
zhanghongtong 3ef08f9ce3 test(meck): add meck unload after meck load 2020-12-22 13:39:49 +08:00
zhanghongtong 26758d48d1 test(auth mnesia): the initial environment is restored at the end of the test case 2020-12-22 13:39:49 +08:00
Shawn 443ff737ed fix(rule_engine): use rpc in emqx_rule_engine_api 2020-12-22 11:18:16 +08:00
Shawn e15c0c325e fix(rule_engine): nested_get value from binary was supported in 4.1 2020-12-22 11:18:16 +08:00
Shawn 86d20b060c fix(metrics): counters not created before incr 'rule.matched' 2020-12-22 11:18:16 +08:00
Shawn c3159420bb feat(funcs): add bitsize/1 and subbits/2,3,6 functions 2020-12-22 11:18:16 +08:00
Yudai Kiyofuji 8a50c70ca3
Merge pull request #3929 from z8674558/feat/coap-acl
feat(coap): use emqx_access_control:check_acl before pub/sub
2020-12-21 16:38:49 +09:00
zhanghongtong 0ef84d2722 fix(auth mnesia): remove the duplicate cli command
style(auth mnesia): fix elvis check failurex

style(auth mnesia): remove the extra symbol
2020-12-19 15:20:46 +08:00
Shawn e72cbd22c4 fix(rule_validator): fill default values when validating the params 2020-12-18 11:08:17 +08:00
z8674558 a564670863 fix(coap): fix the issue the connection with same clientid is not discarded 2020-12-17 15:57:38 +09:00
zhanghongtong fd6cc1a848 test(CI): update actions
add fvt tests

update test cases
2020-12-17 14:23:33 +08:00
Shawn 0a44270932
* fix(dialyzer): remove the dialyzer errors 2020-12-17 10:04:49 +08:00
z8674558 f06ec6baaa chore(lint): fix elvis 2020-12-17 10:55:57 +09:00
z8674558 c89dad559e feat(coap): use emqx_access_control:check_acl before pub/sub 2020-12-17 10:36:51 +09:00
Zaiming Shi d4e7a87807 fix(emqx_stomp): Fix emqx_stomp_protocol xref 2020-12-16 18:39:18 +08:00
Zaiming Shi ab57c19e7a
Merge pull request #3917
Fix dialyzer warnings
2020-12-15 13:50:31 +01:00
ayodele.akingbule 893301db6a fix(emqx_stomp_protocol): fix Dialyzer warnings 2020-12-15 12:45:47 +01:00
ayodele.akingbule ec79523ea5 fix(emqx_rule_actions): fix Dialyzer warnings 2020-12-15 11:39:52 +01:00
ayodele.akingbule 51c62dfe65 fix(emqx_auth_mnesia_api): fix Dialyzer warnings 2020-12-15 11:31:55 +01:00
ayodele.akingbule 8ee98e3f20 fix(emqx_rule_utils): fix Dialyzer warnings 2020-12-15 11:31:55 +01:00
z8674558 66ebcfa301 test(emqx_auth_redis): add test cases for sentinel 2020-12-15 10:35:13 +08:00
JianBo He bddacf5284 test(management): refine the tests 2020-12-14 11:35:05 +08:00
JianBo He 5d98944c94 feat(management): implement the auth-mnesia import/export
All codes picks from emqx-management:dev/e4.2.3
2020-12-14 11:35:05 +08:00
JianBo He 1b016b16f4
Merge branch 'dev/v4.3.0' into refact/avoid_anonymous_funcs 2020-12-14 11:23:13 +08:00
JianBo He 1be1757bbd fix(mongo): avoid function_caluse while query returned other types 2020-12-14 11:13:36 +08:00
JianBo He 27d6b73c37 refactor(mqttsn): avoid saving anonymous functions 2020-12-14 11:13:04 +08:00
Zaiming Shi d60212787b chore(build): remove emqx from app's applications list 2020-12-12 23:02:26 +01:00
Shawn 10dbb5bc96
Fix testcases warns (#3906) 2020-12-11 18:54:48 +08:00
Zaiming Shi 7bdd093ef5 Merge remote-tracking branch 'origin/dev/v4.3.0' into umbrella-fix-build 2020-12-11 08:55:57 +01:00
Zaiming Shi d75b89eadb chore(proj): sync .ci directories 2020-12-11 08:37:14 +01:00
Zaiming Shi 0237abd3d2 chore(emqx_lwm2m): Ensure xml dir copied to build dir 2020-12-11 08:29:45 +01:00
Zaiming Shi 3a91ff8a7b chore(proj): resync apps 2020-12-11 08:19:26 +01:00
ayodele.akingbule b2efcef4b4 fix(emqx_rule_runtime): Dialyzer warnings 2020-12-10 23:34:36 +01:00
ayodele.akingbule 6ffb20e1d4 fix(emqx_auth_mnesia_api): Dialyzer warnings 2020-12-10 23:34:36 +01:00
ayodele.akingbule 7998ea1703 fix(emqx_auth_mnesia): Dialyzer warnings 2020-12-10 23:34:36 +01:00
ayodele.akingbule 5644fdc1f0 fix(emqx_acl_mnesia): Dialyzer warnings 2020-12-10 23:34:36 +01:00
ayodele.akingbule b08d9d5d9b fix(emqx_auth_jwt_svr): Dialyzer warnings 2020-12-10 23:34:36 +01:00
Shawn ed510936fe fix(test): revert the code committed by mistake 2020-12-10 21:37:29 +08:00
Ayodele 56d7b3deb1 Umbrella fix build (#8) 2020-12-10 11:25:25 +01:00
Zaiming Shi fb5ad0559f fix(emqx_exproto_conn): dialyzer warning 2020-12-10 11:22:38 +01:00
Zaiming Shi d3fda0f944 refactor(emqx_coap): pin gen_coap 0.3.1 for dialyzer warning fix 2020-12-10 11:22:38 +01:00
Zaiming Shi 19edda4136 fix(emqx_lwm2m): bump to lwm2m_coap 1.1.2 2020-12-10 11:22:38 +01:00
Ayodele ff99bc10ad Umbrella fix build (#7)
* fix(emqx_auth_mongo): Dialyzer warnings

* fix(emqx_auth_mnesia_api): Dialyzer warnings

* fix(emqx_exhook): Dialyzer warnings
2020-12-10 11:22:38 +01:00
Ayodele 0cb9cbce71 Umbrella fix build (#6)
* fix(emqx_bridge_rpc): Dialyzer warnings

* fix(emqx_coap_app): Dialyzer warnings

* fix(emqx_coap_mqtt_adapter): Dialyzer warnings

* fix(emqx_lwm2m_json): Dialyzer warnings

* fix(emqx_lwm2m_message): Dialyzer warnings

* fix(emqx_mgmt): Dialyzer warnings

* fix(emqx_mgmt_cli): Dialyzer warnings

* fix(emqx_mgmt): Dialyzer warnings

* fix(emqx_bridge_rpc): Dialyzer warnings

* fix(emqx_mgmt): Dialyzer warnings

* fix(emqx_exproto_gcli): Dialyzer warnings
2020-12-10 11:22:38 +01:00
Ayodele 13b67c0d19 Umbrella fix build (#5)
* fix(emqx_auth_jwt): Dialyzer warnings

* fix(emqx_auth_mnesia_cli): Dialyzer warnings

* fix(emqx_bridge_mqtt_cli): Dialyzer warnings

* fix(emqx_bridge_mqtt_cli): Dialyzer warnings

* fix(emqx_auth_redis_sup): Dialyzer warnings

* fix(emqx_bridge_mqtt): Dialyzer warnings

* fix(emqx_auth_pgsql_cli): Dialyzer warnings

* fix(emqx_bridge_mqtt_cli): Dialyzer warnings

* fix(emqx_auth_mnesia_cli): Dialyzer warnings
2020-12-10 11:22:38 +01:00
ayodele.akingbule 18ddde0174 fix(emqx_lwm2m_app): Dialyzer warnings 2020-12-10 11:22:38 +01:00
ayodele.akingbule a03d7045cf fix(emqx_lwm2m_protocol): Dialyzer warnings 2020-12-10 11:22:38 +01:00
ayodele.akingbule 80f56654e2 fix(emqx_psk_file): Dialyzer warnings 2020-12-10 11:22:38 +01:00
ayodele.akingbule 01fe9d3ee7 fix(emqx_psk_file_app): Dialyzer warnings 2020-12-10 11:22:38 +01:00
ayodele.akingbule 7116a22fa5 fix(emqx_psk_file): Dialyzer warnings 2020-12-10 11:22:38 +01:00
ayodele.akingbule 1a8baa9d8a fix(emqx_management): Dialyzer warnings 2020-12-10 11:22:38 +01:00
ayodele.akingbule 37e3b11263 fix(emqx_mgmt_api_alarms): Dialyzer warnings 2020-12-10 11:22:38 +01:00
ayodele.akingbule 8ed5dc0b78 fix(emqx_lwm2m_timer): Dialyzer warnings 2020-12-10 11:22:38 +01:00
ayodele.akingbule a94b70a95e fix(emqx_lua_hook): Dialyzer warnings 2020-12-10 11:22:38 +01:00
ayodele.akingbule 31c6292008 fix(emqx_exproto_conn): Dialyzer warnings 2020-12-10 11:22:38 +01:00
ayodele.akingbule b0ea0e2ddb fix(emqx_exhook_app): Dialyzer warnings 2020-12-10 11:22:38 +01:00
ayodele.akingbule cb4892b8c4 fix(emqx_dashboard_admin): Dialyzer warnings 2020-12-10 11:22:38 +01:00
ayodele.akingbule d54a5300fc fix(emqx_coap_registry): Dialyzer warnings 2020-12-10 11:22:38 +01:00
ayodele.akingbule 950430d5da fix(emqx_coap_ps_topics): Dialyzer warnings 2020-12-10 11:22:38 +01:00
ayodele.akingbule 822460377c fix(emqx_auth_redis_cli): Dialyzer warnings 2020-12-10 11:22:38 +01:00
ayodele.akingbule b5e0386c98 fix(emqx_auth_redis_app): Dialyzer warnings 2020-12-10 11:22:38 +01:00
ayodele.akingbule 0e24e59366 fix(emqx_auth_mysql_app): Dialyzer warnings 2020-12-10 11:22:38 +01:00
ayodele.akingbule 7ba5c1787b fix(emqx_auth_mnesia_cli): Dialyzer warnings 2020-12-10 11:22:38 +01:00
ayodele.akingbule 4905b98c26 fix(emqx_auth_ldap_app): Dialyzer warnings 2020-12-10 11:22:38 +01:00
ayodele.akingbule dc27900260 fix(emqx_auth_jwt_app): Dialyzer warnings 2020-12-10 11:22:38 +01:00
ayodele.akingbule d8c9547a5e fix(emqx_auth_http): Dialyzer warnings 2020-12-10 11:22:38 +01:00
Zaiming Shi c8b866dc63 fix(emqx_rule_engine): Dialyzer warnings 2020-12-10 11:22:38 +01:00
Zaiming Shi 5bb1da5896 fix(emqx_rule_engine_sup): discard ets:new return value 2020-12-10 11:22:38 +01:00
ayodele.akingbule 9db6b3b430 fix(emqx_auth_mnesia_app): Dialyzer warnings 2020-12-10 11:22:38 +01:00
ayodele.akingbule db25660497 fix(emqx_auth_http_app): Dialyzer warnings 2020-12-10 11:22:38 +01:00
Zaiming Shi 39883bdab1 fix(emqx_retainer): Dialyzer warnings 2020-12-10 11:22:38 +01:00
Zaiming Shi 8bb8dc5363 fix(emqx_rule_engine): Dialyzer warnings 2020-12-10 11:22:38 +01:00
Zaiming Shi 692f59afaf fix(emqx_rule_events): Dialyzer warnings 2020-12-10 11:22:38 +01:00
Zaiming Shi 3dc11bc9e1 fix(emqx_rule_funcs): Fix strng:pad calls 2020-12-10 11:22:38 +01:00
Zaiming Shi 526d6f74bb fix(emqx_rule_metrics): Fix type specs 2020-12-10 11:22:38 +01:00
Zaiming Shi a504539097 fix(emqx_rule_registry): Dialyzer warning 2020-12-10 11:22:38 +01:00
Zaiming Shi e58abd916c fix(rule_engine.hrl): Type spec, args map is keyed by binary 2020-12-10 11:22:38 +01:00
Zaiming Shi a59218d008 fix(emqx_plugin_template): Dialyzer wanrings 2020-12-10 11:22:38 +01:00
Zaiming Shi bdfcc2da0e fix(emqx_rule_engine_api): Dialyzer warnings for no_match 2020-12-10 11:22:38 +01:00
Zaiming Shi ff55b0ff45 fix(emqx_rule_runtime): Dialyzer warnings 2020-12-10 11:22:38 +01:00
Zaiming Shi 42ed274ec3 fix(emqx_rule_runtime): Dialyzer warnings 2020-12-10 11:22:38 +01:00
Zaiming Shi 764d5977c1 fix(emqx_rule_engine): Dialyzer warning related to generated code 2020-12-10 11:22:38 +01:00
Zaiming Shi 6a1aae52eb fix(emqx_rule_validator): Dialyzer warning 2020-12-10 11:22:38 +01:00
Zaiming Shi 4cfe4e9940 fix(eqmx_sasl): Dialyzer warning 2020-12-10 11:22:38 +01:00
Shawn 02afda2f3b chore(test): testing the github action 2020-12-10 16:49:32 +08:00
Zaiming Shi baaa4e847d fix(emqx_sn_gateway): Dialyzer warnings 2020-12-10 09:49:24 +01:00
Zaiming Shi 8d853a3445 fix(dialyzer/emqx_sn): Fix unmatched return value warning 2020-12-10 09:37:23 +01:00
Zaiming Shi 2e5a0b799d fix(sn): Fix dialyzer warnings 2020-12-10 09:35:35 +01:00
Zaiming Shi 760ef9210a fix(stomp): Fix dialyzer warnings 2020-12-10 09:35:35 +01:00
Zaiming Shi bcae92ae6d fix(telemetry): Fix dialyzer warning about mnesia dirty op race 2020-12-10 09:35:35 +01:00
Zaiming Shi 996b205299 fix(telemetry): Fix dialyzer warning in emqx_telemetry_api 2020-12-10 09:35:35 +01:00
Shawn 12e0028b77 fix(mgmt): remove schema_registry calls from opensource code 2020-12-10 16:30:48 +08:00
Zaiming Shi ecf69b3464 chore(emqx_lwm2m): Add TEST compiler condition for test code 2020-12-10 09:29:46 +01:00
JianBo He 2b1429fe03 test(stomp): cover the emqx_stom_heartbeat:interval/2 2020-12-10 13:08:03 +08:00
JianBo He 713b4c7804 refactor(stomp): remove transaction module 2020-12-10 12:33:55 +08:00
JianBo He 1263a05bbc refactor(stomp): improve code form naming 2020-12-10 12:33:55 +08:00
JianBo He 9e47d31f79 refactor(stomp): avoid anonymous functions 2020-12-10 12:33:52 +08:00
Shawn 15d048d8ec feat(funcs): add bitsize/1 and subbits/2,3,6 functions
Given following Rule SQL:

```
select
  subbits(payload, 1, 8) as firstByte,
  case
    when firstByte = 123 then 't/{'
    when firstByte = 125 then 't/}'
    else 't/' + str(firstByte)
  end as tp
from "t/#"
```

Input Payload: `{x}`
Output: `{"tp": "t/{", "firstByte": 123}`

Input Payload: `}x`
Output: `{"tp": "t/}", "firstByte": 125}`

Input Payload: `a`
Output: `{"tp": "t/97", "firstByte": 97}`
2020-12-10 11:26:07 +08:00
Shawn 573a4b2df8 chore(rule_engine): sync the code from rule-engine/dev/v4.3.0 2020-12-09 17:58:26 +08:00
JianBo He 49d15d974a build(make): add xref, dialyzer command 2020-12-09 14:21:54 +08:00
Zaiming Shi aac3d79b7d fix(build): pre-compile parse_transform modules 2020-12-09 00:28:39 +01:00
Zaiming Shi 80e1d6cc9d chore(apps): delete LICENSE files for apps 2020-12-08 22:28:46 +01:00
Zaiming Shi 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
Zaiming Shi 7fdbfba06a Merge branch 'umbrella-for-430-auto-sync' into umbrella-for-430 2020-12-08 22:09:59 +01:00
Zaiming Shi 2fda0a1565 chore(apps): Sync again all apps 2020-12-07 21:30:21 +01:00
Zaiming Shi 036eda27f6 chore(rebar): Delete profiles from apps' rebar.config
otherwise rebar3 crashes
2020-12-05 13:36:56 +01:00
Zaiming Shi 9dc68bc18d chore(emqx_exhook): Delete old app.src file 2020-12-05 03:04:33 +01:00
Zaiming Shi db792ec577 chore(apps): Sync again with 4.3.0 2020-12-05 03:02:35 +01:00
Zaiming Shi 8a12018863 Add more cleanups 2020-12-05 02:45:01 +01:00
Zaiming Shi 0fb5fb31a5 refactor(proj) sync 4.3.0 plugins with tracked files 2020-12-05 02:43:04 +01:00
Zaiming Shi 686c006d6e refactor(proj): Add apps 2020-12-04 22:11:53 +01:00
Zaiming Shi 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
Zaiming Shi 2cbd2bc800 chore(app.src): use semver 4.3.0 for apps version base 2020-12-03 19:59:41 +01:00
Zaiming Shi 9382bed9f5 refactor(proj): Move etc and data dir to apps/emqx/ 2020-12-03 12:53:02 +01:00
Zaiming Shi e236196fa6 refactor(emqx_auth_mnesia): use tag e4.2.2
Removed emqx_auth_clientid and emqx_auth_username
because the new version emqx_auth_mnesia has all the features included
2020-12-03 12:52:59 +01:00
Zaiming Shi 5f0f91bb15 Merge branch 'dev/v5.0' into umbrella-for-430 2020-12-02 17:37:34 +01:00
Zaiming Shi 5bb0cccb53 refactor(build): Clean up app version management
Starting from 5.0.0, all apps in apps dir should follow semver
strictly. Do not use the umbrella project's release tags.

The universal tags made sense when we have applications scattered
in different repos. Now since this is an umbrella project, it is
enough to have a single package level version number corelated with
git tag.
2020-12-01 23:22:33 +01:00
Zaiming Shi 2dce1883d5 refactor(build): Deterministic code generation
The rebar plugin grpcbox_plugin always re-generates modules with a
timestamp, which makes the stamping script to always result in a
new stamp after each build.

Issue has been sent
https://github.com/tsloughter/grpcbox_plugin/issues/12
2020-11-26 21:13:30 +01:00
ayodele.akingbule 4eef9f691e refactor(metrics): Add short, medium and long windowsize and expose stats 2020-11-12 12:43:31 +01:00
Zaiming Shi abb74056bd refactor(metrics): Use modified moving average for topic metrics speed 2020-11-12 12:40:36 +01:00
terry-xiaoyu e586119752 fix(project): point the hrl files to emqx_lib 2020-10-31 12:34:52 +08:00
terry-xiaoyu 0cd1c57a54 Migrate plugins from tag 4.2.2 2020-10-31 12:10:19 +08:00
terry-xiaoyu 4108662ba1 feature(project): add util app emqx_libs 2020-10-31 12:06:44 +08:00
terry-xiaoyu 7bea9920b5 feature(project): point header to emqx_libs 2020-10-31 11:00:12 +08:00
JianBo He 485bffadd6 refactor(exhook): improve the exhook implementation 2020-10-31 10:24:28 +08:00
JianBo He d1a87d38ba refactor(exproto): improve the exproto implementation 2020-10-31 10:21:53 +08:00
terry-xiaoyu 18d6647b03 feature(project): move test to apps/emqx/test 2020-10-31 10:17:47 +08:00
terry-xiaoyu 496a805aef feature(project): move priv to apps/emqx/priv 2020-10-31 10:15:25 +08:00
terry-xiaoyu d90c0dacb1 feature(project): move hrl files and emqx_logger.erl to apps/emqx_libs 2020-10-31 09:33:50 +08:00
terry-xiaoyu 5a8efd9d20 feature(project): move src to apps/emqx/src 2020-10-31 09:19:28 +08:00
Feng Lee 8702ab838c 0.9 project structure 2015-06-22 16:18:33 +08:00
Feng Lee 986bf5d911 0.9.0 project structure 2015-06-22 16:03:05 +08:00
Feng f37de3a4a7 willmsg 2015-06-17 13:30:34 +08:00
Feng Lee 02c773bb3f drop 2015-06-17 11:32:12 +08:00
Feng Lee 38e0ba08d2 session, finally count down 2015-06-17 01:25:08 +08:00
Feng Lee 08a64ee97b session 2015-06-16 02:41:03 +08:00
Feng Lee 470ac34a6d merge emqtt to emqttd app 2015-06-15 22:28:34 +08:00
Feng Lee d255a98c09 0.9 2015-06-15 19:55:59 +08:00
Feng Lee c487348c2a merge master, send willmsg when normal terminate 2015-06-15 00:08:27 +08:00
Feng Lee afa0c1819b fix issue #175 2015-06-14 23:56:19 +08:00
Feng Lee 7bfc673c28 publish willmsg when normal exit 2015-06-14 23:51:07 +08:00
Feng Lee a0f90b3ac6 upgrade session 2015-06-14 19:24:03 +08:00
Feng Lee 985fbde26f fix issue #174 - add 'from' field to mqtt_message record 2015-06-14 08:24:17 +08:00
Feng a1d778b081 sync 2015-06-14 07:13:08 +08:00
Feng Lee 9c666cef70 merge session 2015-06-13 12:09:08 +08:00
Feng 30ff3b3f4e SESSION_TAB 2015-06-12 22:47:16 +08:00
Feng 5e0bf3d831 sync with imac 2015-06-12 21:59:37 +08:00
Feng Lee c293ccab13 sync 2015-06-12 18:38:26 +08:00
Feng ddf831f361 session 2015-06-12 17:24:08 +08:00
Feng Lee 882fbb83ca out 2015-06-12 10:37:30 +08:00
Feng Lee 04c2772859 seperate session api and process 2015-06-11 23:40:57 +08:00
Feng Lee 517c7eb7b6 session upgrade 2015-06-11 23:34:53 +08:00
Feng 4313ed0cf3 comment 2015-06-11 13:57:00 +08:00
Feng f857f1ec19 new session 2015-06-11 12:15:20 +08:00
Feng f69b6270fb zenmq 2015-06-11 12:08:18 +08:00
Feng 4c906b19ae new session 2015-06-11 12:07:44 +08:00
Feng Lee 53099f2536 0.9.0 2015-06-11 10:23:13 +08:00
Feng Lee 63933d891a Merge branch 'master' into dev 2015-06-11 00:06:01 +08:00
Feng Lee 051b8604e8 g/2, g/3 2015-06-11 00:05:44 +08:00
Feng Lee c4027dfc16 new queue 2015-06-11 00:05:20 +08:00
Feng Lee db2cc7ba0b git 2015-06-11 00:03:03 +08:00
Feng Lee 5559cd7f58 add alarm 2015-06-11 00:01:25 +08:00
Feng 553fb394f3 vsn 'git' 2015-06-09 11:57:44 +08:00
Feng 2954094619 fix issue #53 - client will receive duplicate messages when overlapping subscription 2015-06-09 11:50:53 +08:00
Feng Lee f0583a1c29 0.8.4 2015-06-08 23:34:09 +08:00
Feng Lee 9d5223dd1a contributors 2015-06-08 23:31:20 +08:00
Feng 789e482a30 inflight, queued 2015-06-06 19:04:02 +08:00
Feng 0407d902d6 Merge branch 'master' into dev 2015-06-05 18:35:10 +08:00
Feng Lee b544bdc10b queue:in new message after old one dropped 2015-06-04 23:13:59 +08:00
Feng Lee 7bbd7bb524 fix doc 2015-06-04 21:18:44 +08:00
Feng Lee ead7b23330 0.8.3 2015-06-03 23:50:31 +08:00
Feng Lee 053ddf6113 fix issue #155 2015-06-03 23:50:02 +08:00
Feng Lee ebad80d690 Merge branch 'master' into dev 2015-06-02 12:56:13 +08:00
Feng Lee 5a75e59dd1 fix mysql auth error 2015-06-02 12:52:40 +08:00
Feng Lee f3dbb7ba54 0.8.2 2015-06-01 17:45:45 +08:00
Feng Lee 391dacee19 Merge branch 'master' of github.com:emqtt/emqtt 2015-06-01 16:42:21 +08:00
Feng Lee 8aa2b8fbed fix the issue that websocket client cannot subscribe '/queue/#' 2015-06-01 16:41:59 +08:00
Feng Lee 5c376b8511 Merge branch 'master' of github.com:emqtt/emqtt 2015-06-01 12:38:11 +08:00
Feng Lee 253717d5a1 ordered_set 2015-05-31 11:40:07 +08:00
Feng Lee 73cb2389d9 add 'sys' flag for mqtt_message 2015-05-31 11:38:26 +08:00
Feng Lee d1ae443650 0.8.1 2015-05-29 16:05:17 +08:00
Feng Lee 5a2dfd2a10 presence and misc fix 2015-05-29 09:54:51 +08:00
Feng Lee 230a348f51 0.9.0 2015-05-29 00:53:47 +08:00
Feng Lee e0bbc72f91 client manager 2015-05-29 00:52:05 +08:00
Feng Lee 0476b6874a Merge branch 'dev' of github.com:emqtt/emqtt into dev 2015-05-28 21:55:48 +08:00
Feng Lee d3616a2701 client presence management 2015-05-28 21:55:20 +08:00
huangdan 2ee3010319 vm ports 2015-05-28 21:04:22 +08:00
Feng Lee 5b36d1b677 Merge branch 'master' into dev 2015-05-28 10:07:18 +08:00
Feng Lee 3ed65b419c fix websocket url 2015-05-28 09:45:37 +08:00
Feng Lee 500b9cb4f8 rm plguins/emqttd_auth_plugins 2015-05-28 01:11:36 +08:00
Feng Lee 750fb939b1 mod presence 2015-05-27 15:32:04 +08:00
Feng Lee 954d46cab3 timestamp/0 2015-05-27 13:14:26 +08:00
Feng Lee aa3f882edf protect from empty clientid 2015-05-26 15:39:02 +08:00
Feng Lee b524cf7806 fix issue #138 2015-05-26 14:50:45 +08:00
Feng Lee 07b9cfa722 shutdown... 2015-05-26 13:21:55 +08:00
Feng Lee 5b16368408 Merge branch 'dev-hd' into dev 2015-05-25 11:41:26 +08:00
Feng Lee 73dbc98068 rewrite 2015-05-25 11:16:06 +08:00
huangdan 379426fa82 Merge branch 'dev' into dev-hd 2015-05-25 10:40:20 +08:00
Feng Lee 46545be9d0 rewrite 2015-05-24 21:54:57 +08:00
Feng Lee c2d4a60dec is_mod_enabled 2015-05-24 21:54:36 +08:00
Feng Lee d19805b68c mod rewrite 2015-05-24 18:33:53 +08:00
Feng Lee 74024acd01 broker hooks 2015-05-24 15:28:56 +08:00
Feng Lee 01bfb830f5 forced subscriptions 2015-05-23 00:20:58 +08:00
Feng Lee f75c807aaf fix pool, table 2015-05-22 18:39:35 +08:00
huangdan bd0c49329b access test 2015-05-20 12:48:34 +08:00
huangdan e674d00330 access get_env 2015-05-20 10:59:57 +08:00
huangdan 54d29160f6 access_control test 2015-05-20 10:43:34 +08:00
Feng Lee e911025811 emqttd_sm_sup 2015-05-19 00:14:20 +08:00
Feng Lee aa703dea36 id 2015-05-19 00:14:10 +08:00
Feng Lee eea6d220d5 0.8.0 2015-05-06 11:59:05 +08:00
Feng Lee 1a883faef2 trace to print payload 2015-05-06 10:23:06 +08:00
Feng Lee dd053a4336 Merge branch 'issue#111' into dev 2015-05-06 02:13:53 +08:00
Feng Lee 955d9c4ef8 fixe issue #111 - forced subscriptions 2015-05-06 01:58:17 +08:00
Feng Lee 0dd046840d add feed_var/3, join/1 2015-05-06 01:00:07 +08:00
Feng Lee 201b7c414a queue support... 2015-05-05 16:41:45 +08:00
Feng Lee 38051426fa user 2015-05-05 12:15:06 +08:00
Feng Lee aae3258beb 0.7.1 2015-05-04 23:31:39 +08:00
Feng Lee 71751960aa fix errors found by dialyzer 2015-05-04 23:27:41 +08:00
Feng Lee a7344248e4 fix issue #121, unload plugins, stop/start gproc app when clustering... 2015-05-04 20:05:16 +08:00
Feng Lee 14421dae5b prep_stop to close listeners 2015-05-04 20:02:51 +08:00
Feng Lee f0b544369b fix issue #123 2015-05-04 19:58:54 +08:00
Feng Lee ac3a17e0e7 env 2015-05-02 00:04:58 +08:00
Feng Lee 2d600711c9 add env/1, merge_sockopts 2015-05-02 00:01:36 +08:00
Feng Lee 27f0b43e90 fix edoc 2015-04-30 12:37:56 +08:00
Feng Lee 914fa668b7 fix issues #118 - protect from empty sub/unsub topic list 2015-04-29 17:11:42 +08:00
Feng Lee 5a43afd07f start_tick, stop_tick 2015-04-29 16:23:26 +08:00
Feng Lee 69611b234d websocket support 2015-04-29 02:19:46 +08:00
Feng Lee 46a273b161 websocket support 2015-04-29 00:43:59 +08:00
Feng Lee 5afe4a62b4 sync with air 2015-04-28 12:25:11 +08:00
Feng Lee 1b96f93ab7 websocket test 2015-04-28 00:14:21 +08:00
Feng Lee 9343a7c419 websocket 2015-04-27 22:37:00 +08:00
Feng Lee 153f8c2dba rm tick 2015-04-27 21:13:29 +08:00
Feng Lee 547f192cae fix stats bug 2015-04-27 12:39:43 +08:00
Feng Lee d99dac81a4 start stats before broker 2015-04-27 12:12:49 +08:00
Feng Lee b4298f2b05 fix options, stats 2015-04-27 12:02:44 +08:00
Feng Lee e88875d2af tick 2015-04-27 10:03:46 +08:00
Feng Lee eb84783d4a sync with imac 2015-04-27 09:14:04 +08:00
Feng Lee 7e63e179da stats 2015-04-25 23:57:38 +08:00
Feng Lee ada53f8b68 merge master 2015-04-25 23:26:56 +08:00
Feng Lee 9f59d86b23 add emqttd_stats 2015-04-25 23:04:12 +08:00
Feng Lee e86f9ac6aa fix duplicated session 2015-04-24 00:55:56 +08:00
Feng Lee 77a26ded12 lookup_session 2015-04-23 23:36:31 +08:00
Feng Lee 70a20591bf 0.6.2 2015-04-23 23:23:08 +08:00
Feng Lee f1632ef2df fix issues #54 2015-04-23 23:20:19 +08:00
Feng Lee cec8ab6b4a rm emqttd_plugin_manager, emqttd.erl to support plugins management 2015-04-23 00:49:53 +08:00
Feng Lee bb2940cfb6 simple plugin mechanism 2015-04-22 16:57:47 +08:00
Feng Lee 504fe99570 code review 2015-04-22 01:31:42 +08:00
Feng Lee f7d44f88f1 close listeners 2015-04-22 00:14:52 +08:00
Feng Lee a9e4414d3c fix issues#93, support trace. 2015-04-21 18:10:02 +08:00
Feng Lee 6907d4feed misc fix 2015-04-21 14:38:18 +08:00
Ery Lee aab6dcf8d1 fix issues#101 - access_control for PUBLISH packet should be optimized 2015-04-21 12:14:27 +08:00
Ery Lee c4c0be44f3 align 2015-04-20 04:47:56 +08:00
Ery Lee fb8833bb86 TAB 2015-04-20 04:31:52 +08:00
Ery Lee eff6bed994 disc copies 2015-04-20 04:31:19 +08:00
Ery Lee 50e033c71d TAB 2015-04-20 04:29:56 +08:00
Ery Lee 02614e8ae4 fix issue#95 - Topic filters in ACL rule should support 'eq' tag 2015-04-20 04:26:01 +08:00
Ery Lee cf0068c2b3 ignore_lib_apps(Apps) 2015-04-20 04:23:54 +08:00
Ery Lee 229bcb6873 retain message when publish 2015-04-20 03:26:09 +08:00
Ery Lee ab84b6ff09 integrate gproc 2015-04-19 19:35:09 +08:00
Feng Lee fd8024821b gproc pool 2015-04-19 12:49:13 +08:00
Ery Lee 8694a825d3 route 2015-04-18 18:36:57 +08:00
Ery Lee 189a16d55e Merge branch 'dev' of github.com:emqtt/emqtt into dev 2015-04-17 01:47:37 +08:00
Ery Lee 843a0be61c comment log 2015-04-17 01:47:24 +08:00
Feng Lee 7956b6d309 acl_mod behaviour 2015-04-17 01:08:32 +08:00
Feng Lee 4bda2c5a43 fix issue #85 2015-04-17 00:48:57 +08:00
Feng Lee 94dd3b042d fix check_acl 2015-04-16 23:51:37 +08:00
Feng Lee 2ed2426a33 access_control 2015-04-16 23:24:07 +08:00
Feng Lee ec48b186c6 access_control to replace acl, auth 2015-04-16 23:08:32 +08:00
Feng Lee f21da05992 Merge branch 'dev' of github.com:emqtt/emqtt into dev 2015-04-16 19:44:57 +08:00
Feng Lee 67c5b08064 misc 2015-04-16 19:44:48 +08:00
Ery Lee 889675e710 acl, auth 2015-04-16 15:50:23 +08:00
Feng Lee 50f2162968 login 2015-04-16 11:43:59 +08:00
Feng Lee 6fedab1e12 fix emqttd_parser, emqttd_serialiser 2015-04-16 11:16:45 +08:00
Feng Lee 684c562cc7 emqttd_utils 2015-04-16 11:07:10 +08:00
Ery Lee a899dada12 msg store 2015-04-16 09:29:53 +08:00
Feng Lee b7a2b66db0 route with clientid 2015-04-15 22:20:19 +08:00
Feng Lee 2d05d1044a mqtt_clientid() 2015-04-15 21:17:25 +08:00
Feng Lee 4fe72445fd route with From 2015-04-15 21:15:09 +08:00
Ery Lee 95652c77d0 trace 2015-04-15 20:47:28 +08:00
Ery Lee 9325c31be6 dump to format 2015-04-15 20:27:46 +08:00
Ery Lee d50507475a emqtt/include/emqtt.hrl 2015-04-15 17:25:34 +08:00
Ery Lee 99633fb815 emqtt.hrl 2015-04-15 17:21:02 +08:00
Ery Lee 8c28bbcc7a refactor records 2015-04-15 12:37:44 +08:00
Feng Lee c54fb8c0ba emqtt app 2015-04-15 01:12:06 +08:00
Ery Lee 2ce7683da0 fix tests 2015-04-14 15:53:44 +08:00
Ery Lee 47f99c5cca fix pubsub 2015-04-14 15:35:41 +08:00
Ery Lee d311a058cc rewrite pubsub 2015-04-14 13:31:25 +08:00
Ery Lee e47e3c1fa8 topic, subscriber 2015-04-13 22:57:09 +08:00
Ery Lee 9b6cb812df rm emqttd_topic.hrl 2015-04-13 21:52:12 +08:00
Ery Lee 6c9fc41c3b rewrite emqttd_pubsub 2015-04-13 21:46:47 +08:00
Ery Lee f2b0449117 upstats 2015-04-13 01:47:04 +08:00
Ery Lee 5d4704acc2 monitor -> sysmon 2015-04-12 23:23:53 +08:00
Ery Lee de7ffc6bca will handle cluster later 2015-04-12 22:55:59 +08:00
Ery Lee 761a3b2a2c redesign retained message store and deliver 2015-04-12 22:52:29 +08:00
Ery Lee 4fb90d1e19 cluster 2015-04-12 21:04:17 +08:00
Ery Lee 16bff40b72 cluster, and fix broker stats 2015-04-12 20:36:07 +08:00
Ery Lee 37fcb85bd4 single bottleneck? 2015-04-11 21:11:32 +08:00
Ery Lee cb6967cd46 TAB -> TABLE 2015-04-10 20:26:40 +08:00
Ery Lee 1a81a4cc68 read_concurrency 2015-04-10 20:24:26 +08:00
Ery Lee c0a42b4288 copy topic_subscriber 2015-04-09 11:40:05 +08:00
Ery Lee 7a979e2c57 cluster 2015-04-08 19:40:22 +08:00
Ery Lee 03806557ef retained messages 2015-04-08 16:02:55 +08:00
Ery Lee 826ca7afca integrate with acl 2015-04-08 02:36:16 +08:00
Feng Lee fa24100514 redesign acl 2015-04-08 00:45:46 +08:00
Ery Lee 8ee3433315 syn with imac 2015-04-07 23:05:27 +08:00
Ery Lee 33be1a87e6 fix issue #75 2015-04-07 17:19:51 +08:00
Ery Lee 174226c0b0 authentication with clientid 2015-04-07 17:12:12 +08:00
Feng Lee 920547b9c5 fix authmod 2015-04-07 13:39:41 +08:00
Feng Lee c864944051 auth 2015-04-07 13:33:05 +08:00
Ery Lee 925b45bb47 auth modules 2015-04-06 22:50:19 +08:00
Ery Lee c49ac06322 acl tests 2015-04-06 14:11:33 +08:00
Ery Lee 088aa5c804 start acl 2015-04-06 12:00:26 +08:00
Ery Lee 18f18fc1a1 acl 2015-04-06 11:52:35 +08:00
Feng Lee 1148451a46 sync with air 2015-04-06 10:15:54 +08:00
Ery Lee 139a58112e tmp 2015-04-06 08:56:27 +08:00
Ery Lee e742d73f70 support acl mods 2015-04-05 23:17:46 +08:00
Ery Lee e4e33c2d5d acl... 2015-03-31 21:33:19 +08:00
Ery Lee 26e296a8f5 {matched, AllowDeny} 2015-03-31 10:40:28 +08:00
Ery Lee d9e60faa24 fix ipaddr match 2015-03-31 10:22:27 +08:00
Ery Lee a791d31490 access test 2015-03-28 00:01:36 +08:00
Ery Lee cd24af6768 acl 2015-03-27 21:05:30 +08:00
Ery Lee e6db7c7854 add spec 2015-03-27 14:30:07 +08:00
Ery Lee db161a2025 access rule 2015-03-27 01:15:25 +08:00
Ery Lee 1428223a2b trace 2015-03-25 23:23:25 +08:00
Ery Lee 5df03ba938 access test 2015-03-25 23:03:03 +08:00
Ery Lee 6aa724ef31 acl 2015-03-25 22:46:47 +08:00
Feng Lee de87edac83 sync 2015-03-25 00:45:04 +08:00
Feng Lee ed69b7c5e4 acl 2015-03-24 23:34:35 +08:00
Ery Lee 3c0c394621 acl doc 2015-03-24 20:46:14 +08:00
Ery Lee 2a9653f8a8 emqttd_ctl vm 2015-03-23 21:35:16 +08:00
Ery Lee d0eb5cddb4 gen_server 2015-03-23 20:57:31 +08:00
Ery Lee a864fda201 mqtt_user with clientid, peername 2015-03-23 19:43:29 +08:00
Feng Lee 40b07c5e4c 0.5.4 2015-03-23 01:42:53 +08:00
Feng Lee 3a7103a728 control commands 2015-03-23 00:06:31 +08:00
Feng Lee 18a5da6691 0.5.3 2015-03-22 23:06:31 +08:00
Feng Lee 21d456fd1f rewrite pubsub 2015-03-22 22:35:50 +08:00
Feng Lee a72fccf28d rewrite 2015-03-22 21:13:40 +08:00
Ery Lee 3b84e5c982 todo 2015-03-22 18:06:40 +08:00
Ery Lee 7a9c30c2d1 infinity 2015-03-20 14:44:07 +08:00
feng 9c2640c8e4 log error -> warning 2015-03-19 23:00:31 +08:00
Ery Lee 87e94f89c8 fix issue#72 2015-03-19 13:15:27 +08:00
Ery Lee 98a69089c5 'acceptor_pool' option to 'acceptors' 2015-03-13 20:18:01 +08:00
Ery Lee 25de5ee94d plugin 2015-03-13 11:52:50 +08:00
Feng Lee 7f12562871 fix issue #67 2015-03-12 23:32:55 +08:00
Ery Lee 557c341106 lager:info -> lager:debug 2015-03-12 21:35:35 +08:00
Ery Lee 77a0e9a85b add # match cases 2015-03-12 21:30:53 +08:00
Ery Lee 399d9e08dc emqtt -> emqttd 2015-03-12 21:16:20 +08:00
Ery Lee 43e1b7e966 support to configure max packet size, fix issue#57 2015-03-12 15:53:52 +08:00
Ery Lee 92d91bd3f2 acl 2015-03-12 12:43:18 +08:00
Ery Lee 31c8ea3b73 add broker, bridges, listeners commands. fix issue #63 2015-03-12 12:17:13 +08:00
Ery Lee c52857f398 add broker, bridges, listeners commands 2015-03-12 12:16:37 +08:00
Ery Lee c5a72bd1fb event manager 2015-03-12 01:13:06 +08:00
Ery Lee bcd354f77d event manager 2015-03-12 00:38:56 +08:00
Ery Lee e61d8b5595 bridge options... 2015-03-11 13:59:50 +08:00
Feng Lee b466b8778b pub_interval = 0 2015-03-11 00:15:27 +08:00
Feng Lee d315b5e22a don't wait for mqtt_user 2015-03-10 22:56:06 +08:00
Ery Lee aca536cd8a rename project name from 'emqtt' to 'emqttd' 2015-03-10 20:09:13 +08:00
Feng Lee 665e7cb26d 0.4.0 2015-03-10 00:21:01 +08:00
Feng Lee 81494e0aa0 format 2015-03-09 23:02:36 +08:00
Ery Lee 9a05181844 retained messages statistics 2015-03-09 16:53:35 +08:00
Ery Lee a5573d0c50 messages statistics 2015-03-09 16:41:39 +08:00
Ery Lee f2293c118a ets:new first 2015-03-09 14:07:54 +08:00
Ery Lee a8a7fd0299 TABLE -> METRIC_TAB 2015-03-09 14:05:40 +08:00
Ery Lee e2c1eda808 client -> clients 2015-03-09 14:05:02 +08:00
Ery Lee 9162e57707 add sessions Topics 2015-03-09 13:37:22 +08:00
Ery Lee 778c34f11d client, session, topics, subscribers statatistics 2015-03-09 13:36:00 +08:00
Ery Lee b26f6f1b1d random tick 2015-03-08 19:19:32 +08:00
Ery Lee 00f39607f1 format 2015-03-08 18:15:30 +08:00
Ery Lee 292b178678 serialise tests 2015-03-08 17:37:04 +08:00
Ery Lee 5e9d2886ff Merge branch 'master' into dev 2015-03-08 17:19:02 +08:00
Ery Lee 3581c149bf Merge branch 'master' of github.com:emqtt/emqtt 2015-03-08 17:18:23 +08:00
Ery Lee 2972b1ee52 fix serialise unsuback 2015-03-08 17:17:57 +08:00
Ery Lee 2aaf5741ca fix all() 2015-03-08 17:06:31 +08:00
Ery Lee a04d127d01 emqtt_pubsub:stats() 2015-03-08 15:39:20 +08:00
Ery Lee ca19a4e9e8 fix systops 2015-03-08 15:34:27 +08:00
Ery Lee dc8b7f032e clients/total, clients/max 2015-03-08 15:34:02 +08:00
Ery Lee 6f67127d77 systopics 2015-03-08 15:04:38 +08:00
Feng Lee c7c7b597c5 getstats 2015-03-08 13:38:59 +08:00
Feng Lee 1fc9eb287d packets stats 2015-03-08 13:22:47 +08:00
Feng Lee 8f81048302 list_to_binary 2015-03-08 12:35:30 +08:00
Feng Lee cff100f706 system topics 2015-03-08 12:23:44 +08:00
Feng Lee e00288f9ce fix issue #60 2015-03-07 22:50:29 +08:00
Feng Lee db39ea7745 metrics, broker test 2015-03-07 22:47:06 +08:00
Ery Lee 82772e4e38 broker metrics 2015-03-07 21:44:17 +08:00
Ery Lee 818d4741a6 broker, metrics 2015-03-07 01:32:21 +08:00
Ery Lee a53cc60573 systop 2015-03-07 01:17:52 +08:00
Feng Lee 7c49abf1db Merge branch 'dev' of github.com:emqtt/emqtt into dev 2015-03-06 23:48:53 +08:00
Feng Lee b842ad69bf Topics 2015-03-06 23:48:22 +08:00
Ery Lee dcda44cff6 add 2015-03-06 21:45:36 +08:00
Ery Lee cc86c95951 fix issue #58, add emqtt_opts:merge/2 2015-03-05 14:43:32 +08:00
Ery Lee b11026788a merge emqttc packet header 2015-03-05 14:42:50 +08:00
Ery Lee c6668c6dc9 comment 2015-03-05 12:09:29 +08:00
Ery Lee e8133366e1 fix format 2015-03-05 02:56:50 +08:00
Feng Lee fb6e3dc066 new -> init 2015-03-05 02:26:22 +08:00
Feng Lee ebd056f60b merge emqttc code 2015-03-05 02:09:32 +08:00
Feng Lee e80a78b66e merge emqttc parser 2015-03-05 01:38:47 +08:00
Ery Lee 9512b18c53 merge emqttc 2015-03-04 22:11:17 +08:00
Ery Lee b84b3e5614 merge emqttc parser, serialiser 2015-03-04 16:49:17 +08:00
Feng Lee bb2e8c9653 fix conflict 2015-03-02 21:26:59 +08:00
Feng Lee a7f4563050 misc fix 2015-03-02 21:25:58 +08:00
Ery Lee 4865afcda9 fix issue #55 2015-03-02 12:01:19 +08:00
Ery Lee cc8aeb6a1f fix sslsocket 2015-03-02 01:57:54 +08:00
Ery Lee 2d2aa2f79a upgrade esockd, mochiweb 2015-03-02 01:40:22 +08:00
Feng Lee 89553dff69 Merge branch 'dev' of github.com:emqtt/emqtt into dev 2015-01-30 20:49:37 +08:00
Feng Lee 601f21182d fix issue #52 2015-01-30 20:48:23 +08:00
Ery Lee 3c44aeecb8 topic type: dynamic or static 2015-01-20 15:48:26 +08:00
Ery Lee 1e93f5f513 bridge 2015-01-20 15:42:05 +08:00
Ery Lee 41471da2e8 0.3.1 fix topic match 2015-01-19 22:08:53 +08:00
Ery Lee 537e18b376 rm oldtopic 2015-01-19 21:51:36 +08:00
Ery Lee c83d6d0e01 topic tests 2015-01-19 21:27:47 +08:00
Ery Lee 04c87c06cc rewrite topic functions 2015-01-19 17:36:54 +08:00
Ery Lee 3ae463960f ok\n 2015-01-18 16:34:01 +08:00
Ery Lee 9afa7c9787 fix route dump 2015-01-18 16:26:44 +08:00
Ery Lee 0b09d8a695 fix bool, and route 2015-01-18 16:22:46 +08:00
Ery Lee e7a4be9669 fix get_value 2015-01-18 16:17:41 +08:00
Ery Lee f637aa45c8 fix issue#44: HTTP API should add Qos parameter 2015-01-18 16:11:53 +08:00
Feng Lee f3057c08e4 0.3.0 changes 2015-01-18 12:57:33 +08:00
Feng Lee 52abcef341 fix retained 2015-01-18 12:12:52 +08:00
Feng Lee f16d56c8b9 retained messages 2015-01-18 11:36:21 +08:00
Ery Lee c803ce0d7a fix function clause 2015-01-17 23:24:53 +08:00
Ery Lee fdfdf494f5 match retained topics 2015-01-17 23:21:54 +08:00
Ery Lee 0ae4a0f1af supervisor_spec 2015-01-17 23:08:59 +08:00
Ery Lee 2f5d7634d2 add gen_event 2015-01-17 22:48:44 +08:00
Ery Lee eedfd41a45 retained messages 2015-01-16 15:48:33 +08:00
Ery Lee 953df5f9f7 retained messages 2015-01-16 15:45:15 +08:00
Ery Lee b68a325301 retained 2015-01-16 12:36:27 +08:00
Ery Lee 75d7e65672 set_flag, unset_flag 2015-01-16 12:35:12 +08:00
Ery Lee 760d6954b3 3.3.1.1 dup: reset dup when route message 2015-01-16 01:54:33 +08:00
Ery Lee e31068787b fix issue#42: Redelivery on reconnect 2015-01-16 01:13:02 +08:00
Ery Lee 46d1749120 fix emqtt_messsage 2015-01-16 00:38:30 +08:00
Ery Lee 69568cfb61 from_packet 2015-01-16 00:25:31 +08:00
Ery Lee efd1fbf4fe fix emqtt_packet:from_packet 2015-01-16 00:20:49 +08:00
Ery Lee 999c2b5ebd supprot qos0, qos1, qos2 2015-01-15 23:50:37 +08:00
Ery Lee 45b63a6b13 fix issue#39 remove old subscription with different Qos #39 2015-01-15 00:03:10 +08:00
Ery Lee 0ae43e316c subscribe, unsubscribe topics 2015-01-15 00:02:05 +08:00
Ery Lee d1ac732b8c validate empty topics 2015-01-14 23:57:17 +08:00
Ery Lee 525a104976 will message 2015-01-14 19:38:35 +08:00
Ery Lee 890b429fad shutdown, keepalive_timeout 2015-01-14 18:25:59 +08:00
Ery Lee 8391eeb1dd destory -> destroy 2015-01-14 17:55:58 +08:00
Ery Lee f54986dd0d session destroy 2015-01-14 17:54:27 +08:00
Ery Lee 40faeddd0e session: reverse cached masseges 2015-01-14 14:15:06 +08:00
Ery Lee fb56eee21d session resume and expired 2015-01-14 14:08:39 +08:00
Ery Lee 85be3eef49 stop when badmsg, badinfo 2015-01-14 13:34:07 +08:00
Ery Lee 22797172a4 fix dispatch 2015-01-14 13:19:34 +08:00
Ery Lee eda40bf232 fix clientid 2015-01-14 13:09:27 +08:00
Ery Lee 946003737c fix clietid validator 2015-01-14 13:05:09 +08:00
Ery Lee 600a3b0e2c session 2015-01-14 12:51:41 +08:00
Ery Lee 0301644793 session 2015-01-13 16:45:53 +08:00
Ery Lee cf37428c91 session 2015-01-13 11:50:10 +08:00
Ery Lee 35ff84a8b7 doc 2015-01-13 00:08:28 +08:00
Ery Lee 8c3558b7ec session management 2015-01-13 00:05:16 +08:00
Feng Lee fedb5c209a session 2015-01-12 19:24:44 +08:00
Ery Lee dccbee2905 support empty clientid 2015-01-12 16:50:16 +08:00
Ery Lee 7bdacc6395 packet tests 2015-01-12 15:12:13 +08:00
Feng Lee 66fab96e1a packet tests 2015-01-12 12:58:04 +08:00
Feng Lee c34eaddcc7 Merge branch 'dev' of github.com:emqtt/emqtt into dev 2015-01-12 12:57:39 +08:00
Ery Lee 4e14d326e2 1 = Qos when PUBREL received 2015-01-12 01:26:17 +08:00
Ery Lee 28c0aeabd7 compile error 2015-01-11 23:54:41 +08:00
Ery Lee 161754871f issue#33: QoS of PUBREL packet should be 1 2015-01-11 23:53:14 +08:00
Ery Lee 3ca3552452 fix {function_clause,[{emqtt_protocol,make_packet,
[7,6]
2015-01-11 23:29:50 +08:00
Feng Lee 3e7452dac2 improve dump 2015-01-11 13:37:55 +08:00
Feng Lee 6c2a5c0b96 dump will 2015-01-11 10:57:46 +08:00
Ery Lee b746e57cdb keepalive resumed 2015-01-11 00:44:28 +08:00
Ery Lee efa1ecc5f4 export send_message 2015-01-11 00:40:59 +08:00
Ery Lee 2deed75c26 dump keepalive 2015-01-11 00:34:27 +08:00
Ery Lee 5d6a70afb2 send connack with State1 2015-01-11 00:26:58 +08:00
Ery Lee a46b0f6a75 info conn 2015-01-11 00:20:34 +08:00
Ery Lee 4f0178ab91 fix dump 2015-01-11 00:19:33 +08:00
Feng Lee 8bbce8d0b7 dump 2015-01-10 23:20:55 +08:00
Ery Lee 899569dd34 fix FORMAT ERROR 2015-01-10 17:00:31 +08:00
Ery Lee ae2c5a4fab round 2015-01-10 16:57:28 +08:00
Ery Lee 5f0c0df458 getstate -> getstat 2015-01-10 16:54:04 +08:00
Ery Lee b351f7c452 fasle -> false 2015-01-10 16:50:00 +08:00
Ery Lee 52c3bc9628 KeepAlive 2015-01-10 16:46:11 +08:00
Ery Lee 24d9b46836 add throttle, bridge 2015-01-10 15:12:42 +08:00
Ery Lee c656844762 comment 2015-01-10 00:17:12 +08:00
Feng Lee 663646f113 packet tests 2015-01-10 00:00:40 +08:00
Feng Lee 6ff4f59a25 frame -> packet 2015-01-10 00:00:16 +08:00
Feng Lee 0a4a241be1 Merge branch 'master' into dev 2015-01-08 22:10:47 +08:00
Feng Lee 5ed1217b0a fix wildcard topics match 2015-01-08 14:40:05 +08:00
Feng Lee c9d3e2d291 mqtt 3.1.1 protocol 2015-01-08 14:25:38 +08:00
Ery Lee 034b1a789f configuration, cluster 2015-01-07 14:22:26 +08:00
Feng Lee 5ab4db7caa tests 2015-01-06 21:54:08 +08:00
Ery Lee b44511af50 queue, router, sm 2015-01-06 21:46:12 +08:00
Ery Lee f1c7185f52 state -> conn_state 2015-01-06 12:17:25 +08:00
Ery Lee e7bb275923 Merge branch 'dev' of github.com:emqtt/emqtt into dev 2015-01-06 11:51:18 +08:00
Ery Lee 1c8ac49b12 misc fix 2015-01-06 11:50:53 +08:00
root 668b39768c pubsut test 2015-01-06 03:39:31 +00:00
Ery Lee a8dcb2bfe3 rm emqtt_log.hrl 2015-01-06 10:46:53 +08:00
Feng Lee 3e6b17146a seperate emqtt_protol from emqtt_client 2015-01-05 23:23:08 +08:00
Feng Lee 484cf8ed79 merge 2015-01-05 13:06:37 +08:00
Feng Lee 5beb38cd68 misc fix 2015-01-05 13:04:53 +08:00
Ery Lee 930e9f4f9f protocol and router 2014-12-30 13:12:17 +08:00
Ery Lee 7ab3194747 Merge branch 'dev' of github.com:emqtt/emqtt into dev 2014-12-29 10:59:10 +08:00
Ery Lee 8569718c23 rm empty line 2014-12-29 10:58:45 +08:00
Feng Lee ec96c155bb merge issue#25 2014-12-28 21:29:58 +08:00
Feng Lee 4a2b586ff9 fix clientId length 2014-12-28 21:27:08 +08:00
Feng Lee 29a8a0f283 move 'process_request' to emqtt_protocol 2014-12-11 15:50:18 +08:00
Feng Lee 20fb39cf3b list -> binary 2014-12-10 19:20:09 +08:00
Feng Lee 5fc497ec1a Merge branch 'dev' of github.com:slimpp/emqtt into dev 2014-12-10 18:23:32 +08:00
Feng Lee e77d25b273 author... 2014-12-10 18:21:37 +08:00
Ery Lee a34ae660dc fix router 2014-12-10 15:10:50 +08:00
Ery Lee a0017c3186 author 2014-12-10 14:20:00 +08:00
Feng Lee 23163edab7 rewrite all modules 2014-12-08 17:40:45 +08:00
Ery Lee 0dbb739416 merge 'slimrt' pubsub module 2014-12-08 13:04:03 +08:00
Feng Lee be019ca033 fix topic 2014-12-08 11:24:07 +08:00
Feng Lee 3865833156 http post support 2014-12-07 14:56:46 +08:00
Feng Lee 4e01e12e25 support http 2014-12-07 14:13:53 +08:00
Feng Lee eed75c5802 go... 2014-12-07 11:56:31 +08:00
Ery Lee f51b961ccc add 2014-12-06 23:11:10 +08:00
Ery Lee d5b6152aa8 0.2.0 upgrade 2014-12-06 23:10:45 +08:00
Ery Lee eb08b6bae0 0.2 2014-12-06 23:10:40 +08:00
Feng Lee 0e0ec66f06 add 2014-12-06 19:52:09 +08:00
Feng Lee d12c5d40b2 integrate with esockd... 2014-12-06 19:50:40 +08:00
Feng Lee 3a6ed9a876 0.2 project structure 2014-12-06 19:12:29 +08:00