yuanbiao/emqx
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
5,001 Commits 393 Branches 684 Tags 74 MiB
baa9fd8255
Commit Graph

676 Commits

Author SHA1 Message Date
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