ec79523ea5
fix(emqx_rule_actions): fix Dialyzer warnings
2020-12-15 11:39:52 +01:00
51c62dfe65
fix(emqx_auth_mnesia_api): fix Dialyzer warnings
2020-12-15 11:31:55 +01:00
8ee98e3f20
fix(emqx_rule_utils): fix Dialyzer warnings
2020-12-15 11:31:55 +01:00
66ebcfa301
test(emqx_auth_redis): add test cases for sentinel
2020-12-15 10:35:13 +08:00
bddacf5284
test(management): refine the tests
2020-12-14 11:35:05 +08:00
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
1b016b16f4
Merge branch 'dev/v4.3.0' into refact/avoid_anonymous_funcs
2020-12-14 11:23:13 +08:00
1be1757bbd
fix(mongo): avoid function_caluse while query returned other types
2020-12-14 11:13:36 +08:00
27d6b73c37
refactor(mqttsn): avoid saving anonymous functions
2020-12-14 11:13:04 +08:00
d60212787b
chore(build): remove emqx from app's applications list
2020-12-12 23:02:26 +01:00
10dbb5bc96
Fix testcases warns ( #3906 )
2020-12-11 18:54:48 +08:00
7bdd093ef5
Merge remote-tracking branch 'origin/dev/v4.3.0' into umbrella-fix-build
2020-12-11 08:55:57 +01:00
d75b89eadb
chore(proj): sync .ci directories
2020-12-11 08:37:14 +01:00
0237abd3d2
chore(emqx_lwm2m): Ensure xml dir copied to build dir
2020-12-11 08:29:45 +01:00
3a91ff8a7b
chore(proj): resync apps
2020-12-11 08:19:26 +01:00
b2efcef4b4
fix(emqx_rule_runtime): Dialyzer warnings
2020-12-10 23:34:36 +01:00
6ffb20e1d4
fix(emqx_auth_mnesia_api): Dialyzer warnings
2020-12-10 23:34:36 +01:00
7998ea1703
fix(emqx_auth_mnesia): Dialyzer warnings
2020-12-10 23:34:36 +01:00
5644fdc1f0
fix(emqx_acl_mnesia): Dialyzer warnings
2020-12-10 23:34:36 +01:00
b08d9d5d9b
fix(emqx_auth_jwt_svr): Dialyzer warnings
2020-12-10 23:34:36 +01:00
ed510936fe
fix(test): revert the code committed by mistake
2020-12-10 21:37:29 +08:00
56d7b3deb1
Umbrella fix build ( #8 )
2020-12-10 11:25:25 +01:00
fb5ad0559f
fix(emqx_exproto_conn): dialyzer warning
2020-12-10 11:22:38 +01:00
d3fda0f944
refactor(emqx_coap): pin gen_coap 0.3.1 for dialyzer warning fix
2020-12-10 11:22:38 +01:00
19edda4136
fix(emqx_lwm2m): bump to lwm2m_coap 1.1.2
2020-12-10 11:22:38 +01:00
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
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
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
18ddde0174
fix(emqx_lwm2m_app): Dialyzer warnings
2020-12-10 11:22:38 +01:00
a03d7045cf
fix(emqx_lwm2m_protocol): Dialyzer warnings
2020-12-10 11:22:38 +01:00
80f56654e2
fix(emqx_psk_file): Dialyzer warnings
2020-12-10 11:22:38 +01:00
01fe9d3ee7
fix(emqx_psk_file_app): Dialyzer warnings
2020-12-10 11:22:38 +01:00
7116a22fa5
fix(emqx_psk_file): Dialyzer warnings
2020-12-10 11:22:38 +01:00
1a8baa9d8a
fix(emqx_management): Dialyzer warnings
2020-12-10 11:22:38 +01:00
37e3b11263
fix(emqx_mgmt_api_alarms): Dialyzer warnings
2020-12-10 11:22:38 +01:00
8ed5dc0b78
fix(emqx_lwm2m_timer): Dialyzer warnings
2020-12-10 11:22:38 +01:00
a94b70a95e
fix(emqx_lua_hook): Dialyzer warnings
2020-12-10 11:22:38 +01:00
31c6292008
fix(emqx_exproto_conn): Dialyzer warnings
2020-12-10 11:22:38 +01:00
b0ea0e2ddb
fix(emqx_exhook_app): Dialyzer warnings
2020-12-10 11:22:38 +01:00
cb4892b8c4
fix(emqx_dashboard_admin): Dialyzer warnings
2020-12-10 11:22:38 +01:00
d54a5300fc
fix(emqx_coap_registry): Dialyzer warnings
2020-12-10 11:22:38 +01:00
950430d5da
fix(emqx_coap_ps_topics): Dialyzer warnings
2020-12-10 11:22:38 +01:00
822460377c
fix(emqx_auth_redis_cli): Dialyzer warnings
2020-12-10 11:22:38 +01:00
b5e0386c98
fix(emqx_auth_redis_app): Dialyzer warnings
2020-12-10 11:22:38 +01:00
0e24e59366
fix(emqx_auth_mysql_app): Dialyzer warnings
2020-12-10 11:22:38 +01:00
7ba5c1787b
fix(emqx_auth_mnesia_cli): Dialyzer warnings
2020-12-10 11:22:38 +01:00
4905b98c26
fix(emqx_auth_ldap_app): Dialyzer warnings
2020-12-10 11:22:38 +01:00
dc27900260
fix(emqx_auth_jwt_app): Dialyzer warnings
2020-12-10 11:22:38 +01:00
d8c9547a5e
fix(emqx_auth_http): Dialyzer warnings
2020-12-10 11:22:38 +01:00
c8b866dc63
fix(emqx_rule_engine): Dialyzer warnings
2020-12-10 11:22:38 +01:00
5bb1da5896
fix(emqx_rule_engine_sup): discard ets:new return value
2020-12-10 11:22:38 +01:00
9db6b3b430
fix(emqx_auth_mnesia_app): Dialyzer warnings
2020-12-10 11:22:38 +01:00
db25660497
fix(emqx_auth_http_app): Dialyzer warnings
2020-12-10 11:22:38 +01:00
39883bdab1
fix(emqx_retainer): Dialyzer warnings
2020-12-10 11:22:38 +01:00
8bb8dc5363
fix(emqx_rule_engine): Dialyzer warnings
2020-12-10 11:22:38 +01:00
692f59afaf
fix(emqx_rule_events): Dialyzer warnings
2020-12-10 11:22:38 +01:00
3dc11bc9e1
fix(emqx_rule_funcs): Fix strng:pad calls
2020-12-10 11:22:38 +01:00
526d6f74bb
fix(emqx_rule_metrics): Fix type specs
2020-12-10 11:22:38 +01:00
a504539097
fix(emqx_rule_registry): Dialyzer warning
2020-12-10 11:22:38 +01:00
e58abd916c
fix(rule_engine.hrl): Type spec, args map is keyed by binary
2020-12-10 11:22:38 +01:00
a59218d008
fix(emqx_plugin_template): Dialyzer wanrings
2020-12-10 11:22:38 +01:00
bdfcc2da0e
fix(emqx_rule_engine_api): Dialyzer warnings for no_match
2020-12-10 11:22:38 +01:00
ff55b0ff45
fix(emqx_rule_runtime): Dialyzer warnings
2020-12-10 11:22:38 +01:00
42ed274ec3
fix(emqx_rule_runtime): Dialyzer warnings
2020-12-10 11:22:38 +01:00
764d5977c1
fix(emqx_rule_engine): Dialyzer warning related to generated code
2020-12-10 11:22:38 +01:00
6a1aae52eb
fix(emqx_rule_validator): Dialyzer warning
2020-12-10 11:22:38 +01:00
4cfe4e9940
fix(eqmx_sasl): Dialyzer warning
2020-12-10 11:22:38 +01:00
02afda2f3b
chore(test): testing the github action
2020-12-10 16:49:32 +08:00
baaa4e847d
fix(emqx_sn_gateway): Dialyzer warnings
2020-12-10 09:49:24 +01:00
8d853a3445
fix(dialyzer/emqx_sn): Fix unmatched return value warning
2020-12-10 09:37:23 +01:00
2e5a0b799d
fix(sn): Fix dialyzer warnings
2020-12-10 09:35:35 +01:00
760ef9210a
fix(stomp): Fix dialyzer warnings
2020-12-10 09:35:35 +01:00
bcae92ae6d
fix(telemetry): Fix dialyzer warning about mnesia dirty op race
2020-12-10 09:35:35 +01:00
996b205299
fix(telemetry): Fix dialyzer warning in emqx_telemetry_api
2020-12-10 09:35:35 +01:00
12e0028b77
fix(mgmt): remove schema_registry calls from opensource code
2020-12-10 16:30:48 +08:00
ecf69b3464
chore(emqx_lwm2m): Add TEST compiler condition for test code
2020-12-10 09:29:46 +01:00
2b1429fe03
test(stomp): cover the emqx_stom_heartbeat:interval/2
2020-12-10 13:08:03 +08:00
713b4c7804
refactor(stomp): remove transaction module
2020-12-10 12:33:55 +08:00
1263a05bbc
refactor(stomp): improve code form naming
2020-12-10 12:33:55 +08:00
9e47d31f79
refactor(stomp): avoid anonymous functions
2020-12-10 12:33:52 +08:00
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
573a4b2df8
chore(rule_engine): sync the code from rule-engine/dev/v4.3.0
2020-12-09 17:58:26 +08:00
49d15d974a
build(make): add xref, dialyzer command
2020-12-09 14:21:54 +08:00
aac3d79b7d
fix(build): pre-compile parse_transform modules
2020-12-09 00:28:39 +01:00
80e1d6cc9d
chore(apps): delete LICENSE files for apps
2020-12-08 22:28:46 +01: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
7fdbfba06a
Merge branch 'umbrella-for-430-auto-sync' into umbrella-for-430
2020-12-08 22:09:59 +01:00
2fda0a1565
chore(apps): Sync again all apps
2020-12-07 21:30:21 +01:00
036eda27f6
chore(rebar): Delete profiles from apps' rebar.config
...
otherwise rebar3 crashes
2020-12-05 13:36:56 +01:00
9dc68bc18d
chore(emqx_exhook): Delete old app.src file
2020-12-05 03:04:33 +01:00
db792ec577
chore(apps): Sync again with 4.3.0
2020-12-05 03:02:35 +01:00
8a12018863
Add more cleanups
2020-12-05 02:45:01 +01:00
0fb5fb31a5
refactor(proj) sync 4.3.0 plugins with tracked files
2020-12-05 02:43:04 +01:00
686c006d6e
refactor(proj): Add apps
2020-12-04 22:11:53 +01: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
2cbd2bc800
chore(app.src): use semver 4.3.0 for apps version base
2020-12-03 19:59:41 +01:00
9382bed9f5
refactor(proj): Move etc and data dir to apps/emqx/
2020-12-03 12:53:02 +01:00
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
5f0f91bb15
Merge branch 'dev/v5.0' into umbrella-for-430
2020-12-02 17:37:34 +01:00
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
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
4eef9f691e
refactor(metrics): Add short, medium and long windowsize and expose stats
2020-11-12 12:43:31 +01:00
abb74056bd
refactor(metrics): Use modified moving average for topic metrics speed
2020-11-12 12:40:36 +01:00
e586119752
fix(project): point the hrl files to emqx_lib
2020-10-31 12:34:52 +08:00
0cd1c57a54
Migrate plugins from tag 4.2.2
2020-10-31 12:10:19 +08:00
4108662ba1
feature(project): add util app emqx_libs
2020-10-31 12:06:44 +08:00
7bea9920b5
feature(project): point header to emqx_libs
2020-10-31 11:00:12 +08:00
485bffadd6
refactor(exhook): improve the exhook implementation
2020-10-31 10:24:28 +08:00
d1a87d38ba
refactor(exproto): improve the exproto implementation
2020-10-31 10:21:53 +08:00
18d6647b03
feature(project): move test to apps/emqx/test
2020-10-31 10:17:47 +08:00
496a805aef
feature(project): move priv to apps/emqx/priv
2020-10-31 10:15:25 +08:00
d90c0dacb1
feature(project): move hrl files and emqx_logger.erl to apps/emqx_libs
2020-10-31 09:33:50 +08:00
5a8efd9d20
feature(project): move src to apps/emqx/src
2020-10-31 09:19:28 +08:00
8702ab838c
0.9 project structure
2015-06-22 16:18:33 +08:00
986bf5d911
0.9.0 project structure
2015-06-22 16:03:05 +08:00
f37de3a4a7
willmsg
2015-06-17 13:30:34 +08:00
02c773bb3f
drop
2015-06-17 11:32:12 +08:00
38e0ba08d2
session, finally count down
2015-06-17 01:25:08 +08:00
08a64ee97b
session
2015-06-16 02:41:03 +08:00
470ac34a6d
merge emqtt to emqttd app
2015-06-15 22:28:34 +08:00
d255a98c09
0.9
2015-06-15 19:55:59 +08:00
c487348c2a
merge master, send willmsg when normal terminate
2015-06-15 00:08:27 +08:00
afa0c1819b
fix issue #175
2015-06-14 23:56:19 +08:00
7bfc673c28
publish willmsg when normal exit
2015-06-14 23:51:07 +08:00
a0f90b3ac6
upgrade session
2015-06-14 19:24:03 +08:00
985fbde26f
fix issue #174 - add 'from' field to mqtt_message record
2015-06-14 08:24:17 +08:00
a1d778b081
sync
2015-06-14 07:13:08 +08:00
9c666cef70
merge session
2015-06-13 12:09:08 +08:00
30ff3b3f4e
SESSION_TAB
2015-06-12 22:47:16 +08:00
5e0bf3d831
sync with imac
2015-06-12 21:59:37 +08:00
c293ccab13
sync
2015-06-12 18:38:26 +08:00
ddf831f361
session
2015-06-12 17:24:08 +08:00
882fbb83ca
out
2015-06-12 10:37:30 +08:00
04c2772859
seperate session api and process
2015-06-11 23:40:57 +08:00
517c7eb7b6
session upgrade
2015-06-11 23:34:53 +08:00
4313ed0cf3
comment
2015-06-11 13:57:00 +08:00
f857f1ec19
new session
2015-06-11 12:15:20 +08:00
f69b6270fb
zenmq
2015-06-11 12:08:18 +08:00
4c906b19ae
new session
2015-06-11 12:07:44 +08:00
53099f2536
0.9.0
2015-06-11 10:23:13 +08:00
63933d891a
Merge branch 'master' into dev
2015-06-11 00:06:01 +08:00
051b8604e8
g/2, g/3
2015-06-11 00:05:44 +08:00
c4027dfc16
new queue
2015-06-11 00:05:20 +08:00
db2cc7ba0b
git
2015-06-11 00:03:03 +08:00
5559cd7f58
add alarm
2015-06-11 00:01:25 +08:00
553fb394f3
vsn 'git'
2015-06-09 11:57:44 +08:00
2954094619
fix issue #53 - client will receive duplicate messages when overlapping subscription
2015-06-09 11:50:53 +08:00
f0583a1c29
0.8.4
2015-06-08 23:34:09 +08:00
9d5223dd1a
contributors
2015-06-08 23:31:20 +08:00
789e482a30
inflight, queued
2015-06-06 19:04:02 +08:00
0407d902d6
Merge branch 'master' into dev
2015-06-05 18:35:10 +08:00
b544bdc10b
queue:in new message after old one dropped
2015-06-04 23:13:59 +08:00
7bbd7bb524
fix doc
2015-06-04 21:18:44 +08:00
ead7b23330
0.8.3
2015-06-03 23:50:31 +08:00
053ddf6113
fix issue #155
2015-06-03 23:50:02 +08:00
ebad80d690
Merge branch 'master' into dev
2015-06-02 12:56:13 +08:00
5a75e59dd1
fix mysql auth error
2015-06-02 12:52:40 +08:00
f3dbb7ba54
0.8.2
2015-06-01 17:45:45 +08:00
391dacee19
Merge branch 'master' of github.com:emqtt/emqtt
2015-06-01 16:42:21 +08:00
8aa2b8fbed
fix the issue that websocket client cannot subscribe '/queue/#'
2015-06-01 16:41:59 +08:00
5c376b8511
Merge branch 'master' of github.com:emqtt/emqtt
2015-06-01 12:38:11 +08:00
253717d5a1
ordered_set
2015-05-31 11:40:07 +08:00
73cb2389d9
add 'sys' flag for mqtt_message
2015-05-31 11:38:26 +08:00
d1ae443650
0.8.1
2015-05-29 16:05:17 +08:00
5a2dfd2a10
presence and misc fix
2015-05-29 09:54:51 +08:00
230a348f51
0.9.0
2015-05-29 00:53:47 +08:00
e0bbc72f91
client manager
2015-05-29 00:52:05 +08:00
0476b6874a
Merge branch 'dev' of github.com:emqtt/emqtt into dev
2015-05-28 21:55:48 +08:00
d3616a2701
client presence management
2015-05-28 21:55:20 +08:00
2ee3010319
vm ports
2015-05-28 21:04:22 +08:00
5b36d1b677
Merge branch 'master' into dev
2015-05-28 10:07:18 +08:00
3ed65b419c
fix websocket url
2015-05-28 09:45:37 +08:00
500b9cb4f8
rm plguins/emqttd_auth_plugins
2015-05-28 01:11:36 +08:00
750fb939b1
mod presence
2015-05-27 15:32:04 +08:00
954d46cab3
timestamp/0
2015-05-27 13:14:26 +08:00
aa3f882edf
protect from empty clientid
2015-05-26 15:39:02 +08:00
b524cf7806
fix issue #138
2015-05-26 14:50:45 +08:00
07b9cfa722
shutdown...
2015-05-26 13:21:55 +08:00
5b16368408
Merge branch 'dev-hd' into dev
2015-05-25 11:41:26 +08:00
73dbc98068
rewrite
2015-05-25 11:16:06 +08:00
379426fa82
Merge branch 'dev' into dev-hd
2015-05-25 10:40:20 +08:00
46545be9d0
rewrite
2015-05-24 21:54:57 +08:00
c2d4a60dec
is_mod_enabled
2015-05-24 21:54:36 +08:00
d19805b68c
mod rewrite
2015-05-24 18:33:53 +08:00
74024acd01
broker hooks
2015-05-24 15:28:56 +08:00
01bfb830f5
forced subscriptions
2015-05-23 00:20:58 +08:00
f75c807aaf
fix pool, table
2015-05-22 18:39:35 +08:00
bd0c49329b
access test
2015-05-20 12:48:34 +08:00
e674d00330
access get_env
2015-05-20 10:59:57 +08:00
54d29160f6
access_control test
2015-05-20 10:43:34 +08:00
e911025811
emqttd_sm_sup
2015-05-19 00:14:20 +08:00
aa703dea36
id
2015-05-19 00:14:10 +08:00
eea6d220d5
0.8.0
2015-05-06 11:59:05 +08:00
1a883faef2
trace to print payload
2015-05-06 10:23:06 +08:00
dd053a4336
Merge branch 'issue#111' into dev
2015-05-06 02:13:53 +08:00
955d9c4ef8
fixe issue #111 - forced subscriptions
2015-05-06 01:58:17 +08:00
0dd046840d
add feed_var/3, join/1
2015-05-06 01:00:07 +08:00
201b7c414a
queue support...
2015-05-05 16:41:45 +08:00
38051426fa
user
2015-05-05 12:15:06 +08:00
aae3258beb
0.7.1
2015-05-04 23:31:39 +08:00
71751960aa
fix errors found by dialyzer
2015-05-04 23:27:41 +08:00
a7344248e4
fix issue #121 , unload plugins, stop/start gproc app when clustering...
2015-05-04 20:05:16 +08:00
14421dae5b
prep_stop to close listeners
2015-05-04 20:02:51 +08:00
f0b544369b
fix issue #123
2015-05-04 19:58:54 +08:00
ac3a17e0e7
env
2015-05-02 00:04:58 +08:00
2d600711c9
add env/1, merge_sockopts
2015-05-02 00:01:36 +08:00
27f0b43e90
fix edoc
2015-04-30 12:37:56 +08:00
914fa668b7
fix issues #118 - protect from empty sub/unsub topic list
2015-04-29 17:11:42 +08:00
5a43afd07f
start_tick, stop_tick
2015-04-29 16:23:26 +08:00
69611b234d
websocket support
2015-04-29 02:19:46 +08:00
46a273b161
websocket support
2015-04-29 00:43:59 +08:00
5afe4a62b4
sync with air
2015-04-28 12:25:11 +08:00
1b96f93ab7
websocket test
2015-04-28 00:14:21 +08:00
9343a7c419
websocket
2015-04-27 22:37:00 +08:00
153f8c2dba
rm tick
2015-04-27 21:13:29 +08:00
547f192cae
fix stats bug
2015-04-27 12:39:43 +08:00
d99dac81a4
start stats before broker
2015-04-27 12:12:49 +08:00
b4298f2b05
fix options, stats
2015-04-27 12:02:44 +08:00
e88875d2af
tick
2015-04-27 10:03:46 +08:00
eb84783d4a
sync with imac
2015-04-27 09:14:04 +08:00
7e63e179da
stats
2015-04-25 23:57:38 +08:00
ada53f8b68
merge master
2015-04-25 23:26:56 +08:00
9f59d86b23
add emqttd_stats
2015-04-25 23:04:12 +08:00
e86f9ac6aa
fix duplicated session
2015-04-24 00:55:56 +08:00
77a26ded12
lookup_session
2015-04-23 23:36:31 +08:00
70a20591bf
0.6.2
2015-04-23 23:23:08 +08:00
f1632ef2df
fix issues #54
2015-04-23 23:20:19 +08:00
cec8ab6b4a
rm emqttd_plugin_manager, emqttd.erl to support plugins management
2015-04-23 00:49:53 +08:00
bb2940cfb6
simple plugin mechanism
2015-04-22 16:57:47 +08:00
504fe99570
code review
2015-04-22 01:31:42 +08:00
f7d44f88f1
close listeners
2015-04-22 00:14:52 +08:00
a9e4414d3c
fix issues#93, support trace.
2015-04-21 18:10:02 +08:00
6907d4feed
misc fix
2015-04-21 14:38:18 +08:00
aab6dcf8d1
fix issues#101 - access_control for PUBLISH packet should be optimized
2015-04-21 12:14:27 +08:00
c4c0be44f3
align
2015-04-20 04:47:56 +08:00
fb8833bb86
TAB
2015-04-20 04:31:52 +08:00
eff6bed994
disc copies
2015-04-20 04:31:19 +08:00
50e033c71d
TAB
2015-04-20 04:29:56 +08:00
02614e8ae4
fix issue#95 - Topic filters in ACL rule should support 'eq' tag
2015-04-20 04:26:01 +08:00
cf0068c2b3
ignore_lib_apps(Apps)
2015-04-20 04:23:54 +08:00
229bcb6873
retain message when publish
2015-04-20 03:26:09 +08:00
ab84b6ff09
integrate gproc
2015-04-19 19:35:09 +08:00
fd8024821b
gproc pool
2015-04-19 12:49:13 +08:00
8694a825d3
route
2015-04-18 18:36:57 +08:00
189a16d55e
Merge branch 'dev' of github.com:emqtt/emqtt into dev
2015-04-17 01:47:37 +08:00
843a0be61c
comment log
2015-04-17 01:47:24 +08:00
7956b6d309
acl_mod behaviour
2015-04-17 01:08:32 +08:00
4bda2c5a43
fix issue #85
2015-04-17 00:48:57 +08:00
94dd3b042d
fix check_acl
2015-04-16 23:51:37 +08:00
2ed2426a33
access_control
2015-04-16 23:24:07 +08:00
ec48b186c6
access_control to replace acl, auth
2015-04-16 23:08:32 +08:00
f21da05992
Merge branch 'dev' of github.com:emqtt/emqtt into dev
2015-04-16 19:44:57 +08:00
67c5b08064
misc
2015-04-16 19:44:48 +08:00
889675e710
acl, auth
2015-04-16 15:50:23 +08:00
50f2162968
login
2015-04-16 11:43:59 +08:00
6fedab1e12
fix emqttd_parser, emqttd_serialiser
2015-04-16 11:16:45 +08:00
684c562cc7
emqttd_utils
2015-04-16 11:07:10 +08:00
a899dada12
msg store
2015-04-16 09:29:53 +08:00
b7a2b66db0
route with clientid
2015-04-15 22:20:19 +08:00
2d05d1044a
mqtt_clientid()
2015-04-15 21:17:25 +08:00
4fe72445fd
route with From
2015-04-15 21:15:09 +08:00
95652c77d0
trace
2015-04-15 20:47:28 +08:00
9325c31be6
dump to format
2015-04-15 20:27:46 +08:00
d50507475a
emqtt/include/emqtt.hrl
2015-04-15 17:25:34 +08:00
99633fb815
emqtt.hrl
2015-04-15 17:21:02 +08:00
8c28bbcc7a
refactor records
2015-04-15 12:37:44 +08:00
c54fb8c0ba
emqtt app
2015-04-15 01:12:06 +08:00
2ce7683da0
fix tests
2015-04-14 15:53:44 +08:00
47f99c5cca
fix pubsub
2015-04-14 15:35:41 +08:00
d311a058cc
rewrite pubsub
2015-04-14 13:31:25 +08:00
e47e3c1fa8
topic, subscriber
2015-04-13 22:57:09 +08:00
9b6cb812df
rm emqttd_topic.hrl
2015-04-13 21:52:12 +08:00
6c9fc41c3b
rewrite emqttd_pubsub
2015-04-13 21:46:47 +08:00
f2b0449117
upstats
2015-04-13 01:47:04 +08:00
5d4704acc2
monitor -> sysmon
2015-04-12 23:23:53 +08:00
de7ffc6bca
will handle cluster later
2015-04-12 22:55:59 +08:00
761a3b2a2c
redesign retained message store and deliver
2015-04-12 22:52:29 +08:00
4fb90d1e19
cluster
2015-04-12 21:04:17 +08:00
16bff40b72
cluster, and fix broker stats
2015-04-12 20:36:07 +08:00
37fcb85bd4
single bottleneck?
2015-04-11 21:11:32 +08:00
cb6967cd46
TAB -> TABLE
2015-04-10 20:26:40 +08:00
1a81a4cc68
read_concurrency
2015-04-10 20:24:26 +08:00
c0a42b4288
copy topic_subscriber
2015-04-09 11:40:05 +08:00
7a979e2c57
cluster
2015-04-08 19:40:22 +08:00
03806557ef
retained messages
2015-04-08 16:02:55 +08:00
826ca7afca
integrate with acl
2015-04-08 02:36:16 +08:00
fa24100514
redesign acl
2015-04-08 00:45:46 +08:00
8ee3433315
syn with imac
2015-04-07 23:05:27 +08:00
33be1a87e6
fix issue #75
2015-04-07 17:19:51 +08:00
174226c0b0
authentication with clientid
2015-04-07 17:12:12 +08:00
920547b9c5
fix authmod
2015-04-07 13:39:41 +08:00
c864944051
auth
2015-04-07 13:33:05 +08:00
925b45bb47
auth modules
2015-04-06 22:50:19 +08:00
c49ac06322
acl tests
2015-04-06 14:11:33 +08:00
088aa5c804
start acl
2015-04-06 12:00:26 +08:00
18f18fc1a1
acl
2015-04-06 11:52:35 +08:00
1148451a46
sync with air
2015-04-06 10:15:54 +08:00
139a58112e
tmp
2015-04-06 08:56:27 +08:00
e742d73f70
support acl mods
2015-04-05 23:17:46 +08:00
e4e33c2d5d
acl...
2015-03-31 21:33:19 +08:00
26e296a8f5
{matched, AllowDeny}
2015-03-31 10:40:28 +08:00
d9e60faa24
fix ipaddr match
2015-03-31 10:22:27 +08:00
a791d31490
access test
2015-03-28 00:01:36 +08:00
cd24af6768
acl
2015-03-27 21:05:30 +08:00
e6db7c7854
add spec
2015-03-27 14:30:07 +08:00
db161a2025
access rule
2015-03-27 01:15:25 +08:00
1428223a2b
trace
2015-03-25 23:23:25 +08:00
5df03ba938
access test
2015-03-25 23:03:03 +08:00
6aa724ef31
acl
2015-03-25 22:46:47 +08:00
de87edac83
sync
2015-03-25 00:45:04 +08:00
ed69b7c5e4
acl
2015-03-24 23:34:35 +08:00
3c0c394621
acl doc
2015-03-24 20:46:14 +08:00
2a9653f8a8
emqttd_ctl vm
2015-03-23 21:35:16 +08:00
d0eb5cddb4
gen_server
2015-03-23 20:57:31 +08:00
a864fda201
mqtt_user with clientid, peername
2015-03-23 19:43:29 +08:00
40b07c5e4c
0.5.4
2015-03-23 01:42:53 +08:00
3a7103a728
control commands
2015-03-23 00:06:31 +08:00
18a5da6691
0.5.3
2015-03-22 23:06:31 +08:00
21d456fd1f
rewrite pubsub
2015-03-22 22:35:50 +08:00
a72fccf28d
rewrite
2015-03-22 21:13:40 +08:00
3b84e5c982
todo
2015-03-22 18:06:40 +08:00
7a9c30c2d1
infinity
2015-03-20 14:44:07 +08:00
9c2640c8e4
log error -> warning
2015-03-19 23:00:31 +08:00
87e94f89c8
fix issue#72
2015-03-19 13:15:27 +08:00
98a69089c5
'acceptor_pool' option to 'acceptors'
2015-03-13 20:18:01 +08:00
25de5ee94d
plugin
2015-03-13 11:52:50 +08:00
7f12562871
fix issue #67
2015-03-12 23:32:55 +08:00
557c341106
lager:info -> lager:debug
2015-03-12 21:35:35 +08:00
77a0e9a85b
add # match cases
2015-03-12 21:30:53 +08:00
399d9e08dc
emqtt -> emqttd
2015-03-12 21:16:20 +08:00
43e1b7e966
support to configure max packet size, fix issue#57
2015-03-12 15:53:52 +08:00
92d91bd3f2
acl
2015-03-12 12:43:18 +08:00
31c8ea3b73
add broker, bridges, listeners commands. fix issue #63
2015-03-12 12:17:13 +08:00
c52857f398
add broker, bridges, listeners commands
2015-03-12 12:16:37 +08:00
c5a72bd1fb
event manager
2015-03-12 01:13:06 +08:00
bcd354f77d
event manager
2015-03-12 00:38:56 +08:00
e61d8b5595
bridge options...
2015-03-11 13:59:50 +08:00
b466b8778b
pub_interval = 0
2015-03-11 00:15:27 +08:00
d315b5e22a
don't wait for mqtt_user
2015-03-10 22:56:06 +08:00
aca536cd8a
rename project name from 'emqtt' to 'emqttd'
2015-03-10 20:09:13 +08:00
665e7cb26d
0.4.0
2015-03-10 00:21:01 +08:00
81494e0aa0
format
2015-03-09 23:02:36 +08:00
9a05181844
retained messages statistics
2015-03-09 16:53:35 +08:00
a5573d0c50
messages statistics
2015-03-09 16:41:39 +08:00
f2293c118a
ets:new first
2015-03-09 14:07:54 +08:00
a8a7fd0299
TABLE -> METRIC_TAB
2015-03-09 14:05:40 +08:00
e2c1eda808
client -> clients
2015-03-09 14:05:02 +08:00
9162e57707
add sessions Topics
2015-03-09 13:37:22 +08:00
778c34f11d
client, session, topics, subscribers statatistics
2015-03-09 13:36:00 +08:00
b26f6f1b1d
random tick
2015-03-08 19:19:32 +08:00
00f39607f1
format
2015-03-08 18:15:30 +08:00
292b178678
serialise tests
2015-03-08 17:37:04 +08:00
5e9d2886ff
Merge branch 'master' into dev
2015-03-08 17:19:02 +08:00
3581c149bf
Merge branch 'master' of github.com:emqtt/emqtt
2015-03-08 17:18:23 +08:00
2972b1ee52
fix serialise unsuback
2015-03-08 17:17:57 +08:00
2aaf5741ca
fix all()
2015-03-08 17:06:31 +08:00
a04d127d01
emqtt_pubsub:stats()
2015-03-08 15:39:20 +08:00
ca19a4e9e8
fix systops
2015-03-08 15:34:27 +08:00
dc8b7f032e
clients/total, clients/max
2015-03-08 15:34:02 +08:00
6f67127d77
systopics
2015-03-08 15:04:38 +08:00
c7c7b597c5
getstats
2015-03-08 13:38:59 +08:00
1fc9eb287d
packets stats
2015-03-08 13:22:47 +08:00
8f81048302
list_to_binary
2015-03-08 12:35:30 +08:00
cff100f706
system topics
2015-03-08 12:23:44 +08:00
e00288f9ce
fix issue #60
2015-03-07 22:50:29 +08:00
db39ea7745
metrics, broker test
2015-03-07 22:47:06 +08:00
82772e4e38
broker metrics
2015-03-07 21:44:17 +08:00
818d4741a6
broker, metrics
2015-03-07 01:32:21 +08:00
a53cc60573
systop
2015-03-07 01:17:52 +08:00
7c49abf1db
Merge branch 'dev' of github.com:emqtt/emqtt into dev
2015-03-06 23:48:53 +08:00
b842ad69bf
Topics
2015-03-06 23:48:22 +08:00
dcda44cff6
add
2015-03-06 21:45:36 +08:00
cc86c95951
fix issue #58 , add emqtt_opts:merge/2
2015-03-05 14:43:32 +08:00
b11026788a
merge emqttc packet header
2015-03-05 14:42:50 +08:00
c6668c6dc9
comment
2015-03-05 12:09:29 +08:00
e8133366e1
fix format
2015-03-05 02:56:50 +08:00
fb6e3dc066
new -> init
2015-03-05 02:26:22 +08:00
ebd056f60b
merge emqttc code
2015-03-05 02:09:32 +08:00
e80a78b66e
merge emqttc parser
2015-03-05 01:38:47 +08:00
9512b18c53
merge emqttc
2015-03-04 22:11:17 +08:00
b84b3e5614
merge emqttc parser, serialiser
2015-03-04 16:49:17 +08:00
bb2e8c9653
fix conflict
2015-03-02 21:26:59 +08:00
a7f4563050
misc fix
2015-03-02 21:25:58 +08:00
4865afcda9
fix issue #55
2015-03-02 12:01:19 +08:00
cc8aeb6a1f
fix sslsocket
2015-03-02 01:57:54 +08:00
2d2aa2f79a
upgrade esockd, mochiweb
2015-03-02 01:40:22 +08:00
89553dff69
Merge branch 'dev' of github.com:emqtt/emqtt into dev
2015-01-30 20:49:37 +08:00
601f21182d
fix issue #52
2015-01-30 20:48:23 +08:00
3c44aeecb8
topic type: dynamic or static
2015-01-20 15:48:26 +08:00
1e93f5f513
bridge
2015-01-20 15:42:05 +08:00
41471da2e8
0.3.1 fix topic match
2015-01-19 22:08:53 +08:00
537e18b376
rm oldtopic
2015-01-19 21:51:36 +08:00
c83d6d0e01
topic tests
2015-01-19 21:27:47 +08:00
04c87c06cc
rewrite topic functions
2015-01-19 17:36:54 +08:00
3ae463960f
ok\n
2015-01-18 16:34:01 +08:00
9afa7c9787
fix route dump
2015-01-18 16:26:44 +08:00
0b09d8a695
fix bool, and route
2015-01-18 16:22:46 +08:00
e7a4be9669
fix get_value
2015-01-18 16:17:41 +08:00
f637aa45c8
fix issue#44: HTTP API should add Qos parameter
2015-01-18 16:11:53 +08:00
f3057c08e4
0.3.0 changes
2015-01-18 12:57:33 +08:00
52abcef341
fix retained
2015-01-18 12:12:52 +08:00
f16d56c8b9
retained messages
2015-01-18 11:36:21 +08:00
c803ce0d7a
fix function clause
2015-01-17 23:24:53 +08:00
fdfdf494f5
match retained topics
2015-01-17 23:21:54 +08:00
0ae4a0f1af
supervisor_spec
2015-01-17 23:08:59 +08:00
2f5d7634d2
add gen_event
2015-01-17 22:48:44 +08:00
eedfd41a45
retained messages
2015-01-16 15:48:33 +08:00
953df5f9f7
retained messages
2015-01-16 15:45:15 +08:00
b68a325301
retained
2015-01-16 12:36:27 +08:00
75d7e65672
set_flag, unset_flag
2015-01-16 12:35:12 +08:00
760d6954b3
3.3.1.1 dup: reset dup when route message
2015-01-16 01:54:33 +08:00
e31068787b
fix issue#42: Redelivery on reconnect
2015-01-16 01:13:02 +08:00
46d1749120
fix emqtt_messsage
2015-01-16 00:38:30 +08:00
69568cfb61
from_packet
2015-01-16 00:25:31 +08:00
efd1fbf4fe
fix emqtt_packet:from_packet
2015-01-16 00:20:49 +08:00
999c2b5ebd
supprot qos0, qos1, qos2
2015-01-15 23:50:37 +08:00
45b63a6b13
fix issue#39 remove old subscription with different Qos #39
2015-01-15 00:03:10 +08:00
0ae43e316c
subscribe, unsubscribe topics
2015-01-15 00:02:05 +08:00
d1ac732b8c
validate empty topics
2015-01-14 23:57:17 +08:00
525a104976
will message
2015-01-14 19:38:35 +08:00
890b429fad
shutdown, keepalive_timeout
2015-01-14 18:25:59 +08:00
8391eeb1dd
destory -> destroy
2015-01-14 17:55:58 +08:00
f54986dd0d
session destroy
2015-01-14 17:54:27 +08:00
40faeddd0e
session: reverse cached masseges
2015-01-14 14:15:06 +08:00
fb56eee21d
session resume and expired
2015-01-14 14:08:39 +08:00
85be3eef49
stop when badmsg, badinfo
2015-01-14 13:34:07 +08:00
22797172a4
fix dispatch
2015-01-14 13:19:34 +08:00
eda40bf232
fix clientid
2015-01-14 13:09:27 +08:00
946003737c
fix clietid validator
2015-01-14 13:05:09 +08:00
600a3b0e2c
session
2015-01-14 12:51:41 +08:00
0301644793
session
2015-01-13 16:45:53 +08:00
cf37428c91
session
2015-01-13 11:50:10 +08:00
35ff84a8b7
doc
2015-01-13 00:08:28 +08:00
8c3558b7ec
session management
2015-01-13 00:05:16 +08:00
fedb5c209a
session
2015-01-12 19:24:44 +08:00
dccbee2905
support empty clientid
2015-01-12 16:50:16 +08:00
7bdacc6395
packet tests
2015-01-12 15:12:13 +08:00
66fab96e1a
packet tests
2015-01-12 12:58:04 +08:00
c34eaddcc7
Merge branch 'dev' of github.com:emqtt/emqtt into dev
2015-01-12 12:57:39 +08:00
4e14d326e2
1 = Qos when PUBREL received
2015-01-12 01:26:17 +08:00
28c0aeabd7
compile error
2015-01-11 23:54:41 +08:00
161754871f
issue#33: QoS of PUBREL packet should be 1
2015-01-11 23:53:14 +08:00
3ca3552452
fix {function_clause,[{emqtt_protocol,make_packet,
...
[7,6]
2015-01-11 23:29:50 +08:00
3e7452dac2
improve dump
2015-01-11 13:37:55 +08:00
6c2a5c0b96
dump will
2015-01-11 10:57:46 +08:00
b746e57cdb
keepalive resumed
2015-01-11 00:44:28 +08:00
efa1ecc5f4
export send_message
2015-01-11 00:40:59 +08:00
2deed75c26
dump keepalive
2015-01-11 00:34:27 +08:00
5d6a70afb2
send connack with State1
2015-01-11 00:26:58 +08:00
a46b0f6a75
info conn
2015-01-11 00:20:34 +08:00
4f0178ab91
fix dump
2015-01-11 00:19:33 +08:00
8bbce8d0b7
dump
2015-01-10 23:20:55 +08:00
899569dd34
fix FORMAT ERROR
2015-01-10 17:00:31 +08:00
ae2c5a4fab
round
2015-01-10 16:57:28 +08:00
5f0c0df458
getstate -> getstat
2015-01-10 16:54:04 +08:00
b351f7c452
fasle -> false
2015-01-10 16:50:00 +08:00
52c3bc9628
KeepAlive
2015-01-10 16:46:11 +08:00
24d9b46836
add throttle, bridge
2015-01-10 15:12:42 +08:00
c656844762
comment
2015-01-10 00:17:12 +08:00
663646f113
packet tests
2015-01-10 00:00:40 +08:00
6ff4f59a25
frame -> packet
2015-01-10 00:00:16 +08:00
0a4a241be1
Merge branch 'master' into dev
2015-01-08 22:10:47 +08:00
5ed1217b0a
fix wildcard topics match
2015-01-08 14:40:05 +08:00
c9d3e2d291
mqtt 3.1.1 protocol
2015-01-08 14:25:38 +08:00
034b1a789f
configuration, cluster
2015-01-07 14:22:26 +08:00
5ab4db7caa
tests
2015-01-06 21:54:08 +08:00
b44511af50
queue, router, sm
2015-01-06 21:46:12 +08:00
f1c7185f52
state -> conn_state
2015-01-06 12:17:25 +08:00
e7bb275923
Merge branch 'dev' of github.com:emqtt/emqtt into dev
2015-01-06 11:51:18 +08:00
1c8ac49b12
misc fix
2015-01-06 11:50:53 +08:00
668b39768c
pubsut test
2015-01-06 03:39:31 +00:00
a8dcb2bfe3
rm emqtt_log.hrl
2015-01-06 10:46:53 +08:00
3e6b17146a
seperate emqtt_protol from emqtt_client
2015-01-05 23:23:08 +08:00
484cf8ed79
merge
2015-01-05 13:06:37 +08:00
5beb38cd68
misc fix
2015-01-05 13:04:53 +08:00
930e9f4f9f
protocol and router
2014-12-30 13:12:17 +08:00
7ab3194747
Merge branch 'dev' of github.com:emqtt/emqtt into dev
2014-12-29 10:59:10 +08:00
8569718c23
rm empty line
2014-12-29 10:58:45 +08:00
ec96c155bb
merge issue#25
2014-12-28 21:29:58 +08:00
4a2b586ff9
fix clientId length
2014-12-28 21:27:08 +08:00
29a8a0f283
move 'process_request' to emqtt_protocol
2014-12-11 15:50:18 +08:00
20fb39cf3b
list -> binary
2014-12-10 19:20:09 +08:00
5fc497ec1a
Merge branch 'dev' of github.com:slimpp/emqtt into dev
2014-12-10 18:23:32 +08:00
e77d25b273
author...
2014-12-10 18:21:37 +08:00
a34ae660dc
fix router
2014-12-10 15:10:50 +08:00
a0017c3186
author
2014-12-10 14:20:00 +08:00
23163edab7
rewrite all modules
2014-12-08 17:40:45 +08:00
0dbb739416
merge 'slimrt' pubsub module
2014-12-08 13:04:03 +08:00
be019ca033
fix topic
2014-12-08 11:24:07 +08:00
3865833156
http post support
2014-12-07 14:56:46 +08:00
4e01e12e25
support http
2014-12-07 14:13:53 +08:00
eed75c5802
go...
2014-12-07 11:56:31 +08:00
f51b961ccc
add
2014-12-06 23:11:10 +08:00
d5b6152aa8
0.2.0 upgrade
2014-12-06 23:10:45 +08:00
eb08b6bae0
0.2
2014-12-06 23:10:40 +08:00
0e0ec66f06
add
2014-12-06 19:52:09 +08:00
d12c5d40b2
integrate with esockd...
2014-12-06 19:50:40 +08:00
3a6ed9a876
0.2 project structure
2014-12-06 19:12:29 +08:00
ayodele.akingbule