02a17a8e96
Add emqttd_ws_client_sup
2016-06-30 14:33:54 +08:00
61a64ea0b0
send(Packet)
2016-06-28 16:44:52 +08:00
842df63605
merge master
2016-06-28 11:27:52 +08:00
2cae8e284a
{simple_one_for_one, 0, 1}
2016-06-27 09:57:07 +08:00
9181c273ed
enhance emqttd_client ratelimit handling
...
This allows rate limits on a client to be queried
and changed dynamically (possibly by plugins), by
exposing additional apis.
`set_rate_limit/2` expects a Ratelimit tuple module of
the form `{module, record}` where module implements
`check(NumBytes, RlTuple) -> {TimeToPause, NewRlTuple}`
It is recommended that the rate limit module also
implement `new` to allow creating new RateLimit records.
See `esockd_ratelimit` for a reference implementation.
2016-06-23 10:34:37 +05:30
b877cec208
Merge branch 'issue#599' into emq10
2016-06-21 11:35:25 +08:00
0aa8a82e59
ensure the mqtt listener is started successfully
2016-06-21 11:33:23 +08:00
fe3becbf9b
Fix issue#599 - Reject empty clientId with non-clean session
2016-06-21 11:29:59 +08:00
83b25fe84a
2.0
2016-06-20 12:18:49 +08:00
bf2e1c39c3
1.1.2
2016-06-18 14:10:22 +08:00
eaf254e919
Merge branch 'master' into plus
2016-06-05 12:51:35 +08:00
0dea9d0bb0
1.1.1
2016-06-05 12:37:19 +08:00
8a908b43d5
Fix the incompatible Qos
2016-06-04 12:07:54 +08:00
faa7ae2886
Fix issue#575
2016-06-01 11:52:21 +08:00
b26455a512
ListenOn
2016-05-27 17:32:34 +08:00
b4ac98f9c2
Merge pull request #568 from emqtt/issue#561
...
GC after a session DOWN
2016-05-26 19:52:02 +08:00
176b0b64ea
GC after a session DOWN
2016-05-26 19:50:08 +08:00
66d4abce14
1.1
2016-05-23 15:21:13 +08:00
40264564af
esockd_cidr
2016-05-23 15:21:04 +08:00
820806d4f0
esockd_cidr
2016-05-23 15:20:56 +08:00
e16f8506ef
base62 encode/decode
2016-05-17 10:36:09 +08:00
c7ecc0ace0
merge emq10
2016-05-07 10:30:22 +08:00
3ef099389a
1.1
2016-05-05 18:18:50 +08:00
6245d24c83
{error, already_existed}
2016-05-05 15:44:36 +08:00
f50efa5813
fix issue#542
2016-05-05 15:36:44 +08:00
dae1cc1f81
1.0.2 release
2016-05-04 01:02:00 +08:00
76851e58fb
atom_to_list(Username)
2016-05-03 18:31:58 +08:00
9b71f9f6c0
new plugin mechanism
2016-05-03 18:02:41 +08:00
3aef962a07
2.0
2016-05-02 22:31:28 +08:00
1e89fcec1e
Merge pull request #537 from emqtt/issue#534
...
Fix issue#534 - Add './bin/emqttd_ctl vm ports' CLI
2016-04-29 00:23:39 +08:00
17d1598688
Fix issue#534 - Add './bin/emqttd_ctl vm ports' CLI
2016-04-29 00:23:57 +08:00
f5adafe9e2
fix issue #535
2016-04-29 00:17:07 +08:00
4d8f7ffb88
1.0.1
2016-04-16 14:38:22 +08:00
a0319d9d26
Fix queue dispatch
2016-04-14 18:23:01 +08:00
31557eba05
1.0
2016-04-13 02:20:44 +08:00
b8a5ff2314
fix issue #503
2016-04-12 20:34:41 +08:00
3733574105
fix issue #500
2016-04-12 15:11:01 +08:00
b257423730
more test cases for parer
2016-04-12 11:19:55 +08:00
fa67becc3b
Merge pull request #499 from callbay/master
...
matches for the remaining length field in the variable header
2016-04-12 10:12:27 +08:00
d6528886cc
matches for the remaining length field in the variable header
2016-04-07 14:33:39 +08:00
a758423a2e
fix issue #486 - gen_server2:call/3 to register a client
2016-03-30 19:33:53 +08:00
4495d61c62
a
2016-03-26 19:01:33 +08:00
fffbd3dd1e
hibernate
2016-03-22 18:14:13 +08:00
e88fe8b6ae
fix issue #479
2016-03-21 10:08:59 +08:00
2a16888f07
0.17.1
2016-03-21 09:54:24 +08:00
467c6307f6
keepalive * 1.25
2016-03-15 00:58:35 +08:00
e08dbf82f6
remove a transaction
2016-03-14 15:48:39 +08:00
9584f2a990
trans, and stats_timer
2016-03-14 15:47:31 +08:00
50a11ce6c9
-spec().
2016-03-14 14:20:10 +08:00
17f40f458f
if_subsciption, async_subscribe
2016-03-14 13:21:35 +08:00
b08bd5a578
retained_message
2016-03-12 16:38:30 +08:00
ba5fcfdfae
merge PR#462
2016-03-12 15:55:17 +08:00
e32d85f40a
backend and retained_message
2016-03-12 15:39:19 +08:00
0a9ecf833a
export_type
2016-03-12 01:11:06 +08:00
72d9ed2024
emqttd:publish|subscribe
2016-03-12 00:30:37 +08:00
978413298d
HTTP Publish: support 'topics' parameter
2016-03-11 23:45:03 +08:00
37fa9a2f9b
return ok | {error, any()}
2016-03-11 23:43:41 +08:00
d9d7581013
0.17.0 - Improve the design of Hook, PubSub and Router
2016-03-11 23:42:37 +08:00
faf05eb85a
test cases for server, pubsub and router
2016-03-11 23:19:17 +08:00
f1f58818d5
backend_subscription
2016-03-08 13:50:41 +08:00
0f1347a495
add 'routes' command, improve usage
2016-03-08 13:28:11 +08:00
fb273f0eca
disc_copies
2016-03-08 13:27:17 +08:00
16d488adca
emqttd:publish/1
2016-03-08 13:26:46 +08:00
26655f1ee3
emqttd:publish/1
2016-03-08 13:25:19 +08:00
73b7de7cb0
emqttd:publish
2016-03-08 13:21:17 +08:00
67f1e15d4a
start_listeners, stop_listeners
2016-03-08 13:20:50 +08:00
ef8cff4cac
emqttd:publish/1
2016-03-08 13:19:03 +08:00
34493b6fec
update PRINT_CMD
2016-03-08 13:17:04 +08:00
52adc66bda
move start_listeners/0, stop_listeners/0 to emqttd_app.erl, add publish/subscribe APIs
2016-03-08 13:15:50 +08:00
9c9633ab27
just to make it more readable
2016-03-05 23:12:25 +08:00
d6b4ff654a
add 'sys' flag to message
2016-03-05 21:16:16 +08:00
652f5f5767
fix issue #450 . Print a hint if the auth_username module is not enabled
2016-03-03 11:12:08 +08:00
cf4dfe632f
Issue #460 - Timer Tick at interval of (Keepalive * 1.5)/2
2016-03-01 18:59:12 +08:00
d1bb0e04fd
fix syntax error
2016-02-28 23:49:10 +08:00
e40775f1f1
fix issue #438
2016-02-21 10:06:14 +08:00
5695ba178c
cli common tests
2016-02-17 23:52:04 +08:00
369c5e86c5
fix issue #438 - Bridge emqttd broker to another emqttd broker & emqttd to mosquitto bridge
2016-02-17 21:15:34 +08:00
955d8e37fd
router_pool/1
2016-02-16 03:03:16 +08:00
757d1f5fc5
Merge branch 'master' into 0.16
2016-02-16 02:56:59 +08:00
6930439158
-compile(export_all)
2016-02-16 02:54:29 +08:00
8ba6c5bbb6
foreach
2016-02-16 02:17:14 +08:00
e605dcb111
fix spec of wildcard/1
2016-02-16 02:16:55 +08:00
87a2f2680c
rm priority flag
2016-02-16 02:16:30 +08:00
3d2cb93ebd
rm -ifdef(TEST)
2016-02-16 02:16:14 +08:00
3561680697
rm lager:error log
2016-02-16 02:15:52 +08:00
9cb0fe3f0a
more test cases
2016-02-14 01:50:51 +08:00
dfdad8bcb6
refactor the router and pubsub
2016-02-14 01:48:49 +08:00
0d21e5c911
fix issue #440 - mqtt_message record: add 'sender' field
2016-02-14 00:35:42 +08:00
150c103cfa
replace emqttd_opts:g/3 with proplists:get_value/3
2016-02-13 18:36:33 +08:00
541af6256d
replace emqttd_opts:g/3 with proplists:get_value/3
2016-02-13 18:36:09 +08:00
49a979a25e
replace emqttd_opts:g/3 with proplists:get_value/3
2016-02-13 18:35:53 +08:00
1b61ef0856
rm g/2, g/3
2016-02-13 18:35:10 +08:00
890de0c60a
is_queue/1, -ifdef(TEST).
2016-02-13 18:34:28 +08:00
3c53cf2b09
merge zenmq_trie, zenmq_mnesia, zenmq_boot
2016-02-13 14:26:40 +08:00
bd1e618cc8
rewrite emqttd_node module
2016-02-11 15:55:10 +08:00
767c4ccc6e
fix issue #449 - Improve the CLI of cluster
2016-02-11 15:54:35 +08:00
44d598fd87
rm reg_name/2, seed_now/0 functions
2016-02-11 15:53:23 +08:00
89052d8e6e
add emqttd_time module, fix comments and format
2016-02-11 15:52:59 +08:00
1560386ab2
Fix delete/1, add lookup/1
2016-02-11 15:42:29 +08:00
3f047a1d16
add emqttd_time module
2016-02-11 14:33:42 +08:00
9dda709aa1
move running_nodes/0 to emqttd_mnesia and improve some functions
2016-02-11 14:31:42 +08:00
a5116c7fa6
emqttd_time to replace emqttd_util
2016-02-11 14:30:08 +08:00
8aad88e825
fix issue #449 - Improve the design of cluster
2016-02-11 01:42:09 +08:00
e030454466
if only one core, the router will not work
2016-02-06 16:35:33 +08:00
94c3e69b44
Licensed under the Apache, Version 2.0
2016-02-05 14:26:17 +08:00
1e852ded91
0.16 - support static subscriptions
2016-02-02 13:36:52 +08:00
5306463b7e
updated copyright
2016-02-01 11:59:44 +08:00
f65676c232
fix plen/2 - return 0
2016-01-25 14:46:30 +08:00
d8c116a502
add now_to_ms/0, now_to_ms/1 functions
2016-01-25 12:59:41 +08:00
83d64308c5
plen/2 spec
2016-01-24 14:15:34 +08:00
8934d8ecad
stop/1, emqttd:seed_now/0
2016-01-24 13:43:42 +08:00
0b686da281
iolist_to_binary(Name)
2016-01-24 13:42:59 +08:00
22a282e39e
emqttd:seed_now/0 to replace random:seed(now())
2016-01-24 13:42:22 +08:00
fb32c509ce
-spec stats/1
2016-01-23 22:52:50 +08:00
4ebdbd75a3
add out/2, plen/1
2016-01-23 22:04:36 +08:00
166e085fff
add client_connected/3
2016-01-21 15:37:25 +08:00
7193bf4f20
rm bin/1
2016-01-21 12:46:43 +08:00
4934bf54c0
add passwd_hash/2 api
2016-01-20 15:38:51 +08:00
b5c514b39c
fix dispatch
2016-01-20 15:38:24 +08:00
284abc7388
fix reverse_route stats
2016-01-17 20:03:47 +08:00
51c5ea1f96
fix route, reverse_route stats
2016-01-17 20:02:44 +08:00
4f9d429478
fix pubsub, sessions, trace commands
2016-01-17 20:02:13 +08:00
a983361121
fix issue#428 - Username/Password Authentication: support to configure default users
2016-01-17 20:01:36 +08:00
1cbdc5e9e4
use emqttd:reg_name/2 to replace name/1
2016-01-17 20:00:46 +08:00
5bfd3a784e
setstats after route table changed
2016-01-17 20:00:23 +08:00
43165a5e8a
use emqttd:reg_name/2 to replace name/1
2016-01-17 19:59:33 +08:00
0a29c8760e
add reg_name/2 function
2016-01-17 19:59:05 +08:00
2544786c56
add_routes([], _Pid)
2016-01-16 10:40:37 +08:00
21cb2bea6e
2016
2016-01-15 13:43:22 +08:00
b46c8d2f0f
Move github wiki to redthedocs
2016-01-14 17:20:01 +08:00
4e474ee8b9
fix issue #427 - Optimization for Route ETS insertion
2016-01-12 14:10:50 +08:00
3745d7a24b
router pool sup
2016-01-12 14:09:31 +08:00
ba5541c768
Move the aging code to router
2016-01-12 14:02:21 +08:00
20ede24d83
fix issue #427 - Optimization for Route ETS insertion
2016-01-12 14:01:28 +08:00
6e3ae6412d
-type topic() :: binary().
2016-01-12 13:58:24 +08:00
78f2a83a82
0.15
2016-01-07 13:21:14 +08:00
1809d0960d
~p
2016-01-02 17:01:24 +08:00
32b1448204
0.14.1
2015-12-28 20:20:24 +08:00
4a175bfc68
fix spec
2015-12-28 20:18:31 +08:00
4ec480af0b
fix spec
2015-12-28 20:17:18 +08:00
e6e77953f1
delete
2015-12-27 21:56:31 +08:00
2dd8c3d778
remove trap_exit flag, and fix issue #413
2015-12-23 23:20:05 +08:00
78dd1f8838
fix issue #413
2015-12-23 22:33:49 +08:00
6ec5eccd69
fix issue #411
2015-12-17 17:30:49 +08:00
be390d42ac
stop
2015-12-17 14:12:45 +08:00
7ffa25c655
destroy
2015-12-17 14:12:35 +08:00
fe82fde717
subscription
2015-12-17 12:38:13 +08:00
e37b00a9e4
fix subscriptions cli
2015-12-16 11:04:51 +08:00
7cd5367f3b
binary
2015-12-16 11:04:20 +08:00
d3ee464789
topics, subscriptions
2015-12-16 10:22:37 +08:00
b172a78fcd
lookup/2, tune_qos
2015-12-16 10:18:28 +08:00
787a427fda
fix load/1 return
2015-12-10 21:30:26 +08:00
ab556b6bda
rm subscriptions from sess_info
2015-12-10 16:49:58 +08:00
11bdcf1017
fix already_exists
2015-12-10 15:55:24 +08:00
2dd6d160f3
format
2015-12-10 15:04:13 +08:00
26893c764c
serilize
2015-12-10 14:09:05 +08:00
e1e09599ef
Merge branch '0.14' of github.com:emqtt/emqttd into 0.14
2015-12-09 15:41:37 +08:00
05bf24b33b
serializer
2015-12-09 15:41:03 +08:00
00f362fabc
publish(To, ...
2015-12-07 21:35:06 +08:00
3a8ada21e0
dispatch
2015-12-07 21:30:58 +08:00
3d8e91bc20
comment io:format
2015-12-07 21:30:45 +08:00
9e0fe19c25
qos
2015-12-07 21:20:35 +08:00
fd6a350d9c
dispatch
2015-12-07 21:19:12 +08:00
df5daaac5b
dispatch
2015-12-07 21:17:30 +08:00
af02965555
comment start_tracelog
2015-12-07 18:38:07 +08:00
fe69fd95c8
{read_concurrency, true}
2015-12-07 17:12:45 +08:00
4cde27d724
read_concurrency
2015-12-07 14:33:23 +08:00
8f22b0ffbc
route
2015-12-07 00:22:40 +08:00
f4d09c973d
remove mnesia index
2015-12-06 20:32:03 +08:00
c29fd68dd5
storage_properties
2015-12-06 20:30:59 +08:00
a261f3c678
emqtt log
2015-12-06 12:03:05 +08:00
17896c7e77
fix issue #161 - Feature Request - Log Topics
2015-12-06 11:28:05 +08:00
b0ada8ae56
fmt
2015-12-05 20:06:41 +08:00
e3cd170683
0.14
2015-12-05 15:43:49 +08:00
855152f653
spec/1
2015-12-05 02:18:06 +08:00
0c13490092
os:timestamp
2015-12-05 02:13:22 +08:00
1ca477ffa1
monitors
2015-12-05 02:12:27 +08:00
d6a528e0f7
0.14 refactor
2015-12-04 23:53:42 +08:00
812779004f
new pubsub
2015-12-04 17:36:09 +08:00
cfaa0c5e40
0.14
2015-12-03 22:28:39 +08:00
4deb96dc91
0.14
2015-12-03 21:17:07 +08:00
86460cdebc
0.14
2015-12-03 21:15:25 +08:00
392b008a43
TODO: subscriptions
2015-12-03 13:14:32 +08:00
80117c1e8a
rewrite pubsub, router
2015-12-03 12:56:13 +08:00
db8b7c9d82
0.14
2015-12-02 18:01:51 +08:00
16f23406a4
0.14
2015-12-02 18:01:26 +08:00
0b1540f1db
comment process_flag(priority, high)
2015-11-28 11:26:53 +08:00
e78d4fc39b
fix issue #383
2015-11-27 22:36:12 +08:00
df8414dbdc
0.13.1
2015-11-27 21:01:18 +08:00
2d1066517f
Msg =
2015-11-14 14:44:25 +08:00
e05f0cb5b1
Merge pull request #382 from emqtt/chat
...
QOS0/1/2, Pooler Error
2015-11-14 10:46:45 +08:00
860183f931
chat
2015-11-12 13:07:46 +08:00
9effc2fad7
monitors
2015-11-11 12:18:13 +08:00
4fb018203e
fix issue #377
2015-11-11 09:46:23 +08:00
7d54cd8e5d
rate limit log
2015-11-08 14:42:38 +08:00
e25856e9a1
fix issue #374
2015-11-07 23:09:31 +08:00
21a5f3ee33
hibernate
2015-11-07 22:45:57 +08:00
64a34b216c
format
2015-11-07 20:46:31 +08:00
bdea67cf2c
Merge pull request #371 from emqtt/0.13
...
fix issue #357 - Cannot kick transient client out when clientId colli…
2015-11-06 21:31:12 +08:00
59b401c506
fix issue #357 - Cannot kick transient client out when clientId collision
2015-11-06 21:26:46 +08:00
38fb211719
Merge branch 'master' of github.com:emqtt/emqttd
2015-11-06 12:30:27 +08:00
d227ba3ced
warning
2015-11-06 12:30:07 +08:00
4e0220ae81
ok
2015-11-05 12:40:06 +08:00
22889f552c
fix issue #163 - Protocol Compliant - Session Present Flag
2015-11-05 12:29:29 +08:00
8491467bbb
support 'and', 'or'
2015-11-04 21:42:17 +08:00
d09721301e
conflict
2015-11-04 10:22:49 +08:00
9bad2bf65b
support Seq
2015-11-03 12:52:27 +08:00
ea564ec8ef
mod
2015-11-02 20:34:23 +08:00
ecc0f052ef
reply
2015-11-02 15:51:34 +08:00
cff4ca0296
vsn
2015-11-02 15:51:24 +08:00
3c69d1a5c1
fix log
2015-11-02 15:00:43 +08:00
83d4801fe8
disc_copies
2015-11-01 20:45:13 +08:00
4b26291cb9
client(State)
2015-11-01 20:44:21 +08:00
c7f0e33674
rate limit
2015-11-01 16:03:32 +08:00
cf95c5e1b9
0.13 refactor
2015-10-31 18:43:04 +08:00
3f41a6c241
peername
2015-10-31 15:08:25 +08:00
f9027ed1f4
fix issue #367 - Fix the order of emqttd_app:start_server/1
2015-10-31 15:07:50 +08:00
b9962d697c
0.13.0
2015-10-30 21:23:17 +08:00
4ed62d018e
refactor log
2015-10-30 21:20:37 +08:00
19930b6382
refactor protocol
2015-10-30 18:00:23 +08:00
f6636a9783
refactor client
2015-10-30 16:03:25 +08:00
f4cf90ae91
refactor client
2015-10-30 16:00:11 +08:00
565c8abb3a
improve suback
2015-10-26 16:30:39 +08:00
47710c36aa
port_command
2015-10-26 09:25:57 +08:00
976c7653f3
use esockd_rate_limiter
2015-10-26 09:25:40 +08:00
f58f42196a
0.12.4
2015-10-26 09:21:24 +08:00
2af91ea140
link with client
2015-10-26 09:21:03 +08:00
fb9f1bf8e4
rate_limit
2015-10-26 09:20:13 +08:00
59ca283eb0
gen_server
2015-10-23 18:06:35 +08:00
fd7276c587
0.12.3
2015-10-22 10:31:29 +08:00
8bddc3e327
comment binary
2015-10-22 10:31:03 +08:00
52d63125d3
improve log and fix issue #353
2015-10-21 21:36:56 +08:00
86ea9c844f
fix issue #350
2015-10-21 21:18:36 +08:00
7530bfb5fa
ets:insert
2015-10-19 09:45:36 +08:00
6faf488701
ets:insert
2015-10-19 09:45:31 +08:00
67ebff26ce
0.12.2
2015-10-16 15:07:25 +08:00
a35d51ea24
fix issue #346
2015-10-16 14:58:51 +08:00
fae3e1e32f
AckFun
2015-10-15 18:59:51 +08:00
221124d7b2
fix issue #266 - will not count publish
2015-10-14 19:07:41 +08:00
e3b5c6be4e
PUBLISH_PACKET
2015-10-14 18:56:43 +08:00
3dd42b65cf
/status
2015-10-13 23:03:02 +08:00
a16e527975
0.12.1 refactor
2015-10-13 21:09:13 +08:00
05ff1ab002
gen_event
2015-10-13 21:08:56 +08:00
ebf203a931
refactor metrics
2015-10-13 21:05:11 +08:00
6a66ca90b1
concat
2015-10-13 21:04:15 +08:00
5daeac083c
spec
2015-10-13 21:03:25 +08:00
43523f2a1c
received/sent metrics
2015-10-13 21:03:01 +08:00
d3e39ae9a3
src/emqttd_mod_rewrite.erl
2015-10-13 21:01:53 +08:00
a055a0a0c8
IS_PUBSUB
2015-10-13 20:56:10 +08:00
192dc85304
id
2015-10-13 20:55:33 +08:00
063f59f846
fix process_info
2015-10-12 21:07:05 +08:00
d4a434176a
sysmon
2015-10-12 21:06:47 +08:00
6209d47aae
name
2015-10-12 21:06:18 +08:00
4825591565
name
2015-10-12 21:06:01 +08:00
deaf220343
sysmon
2015-10-12 21:05:37 +08:00
47e3e826dc
0.12.1
2015-10-12 21:03:01 +08:00
20cfc2754c
broker
2015-10-11 21:10:47 +08:00
8eb54cc2c3
fix issue #68 - /# topics will not match #, +/#
2015-10-11 15:27:56 +08:00
87b5245494
rm space
2015-10-11 04:02:33 +08:00
13001396de
cli
2015-10-11 03:03:07 +08:00
b9b75fdb65
add 'dist' module
2015-10-11 02:48:32 +08:00
6bc3e70f46
export node_name/1
2015-10-10 20:12:24 +08:00
7af13af848
warning
2015-10-10 19:56:43 +08:00
aad1f3547f
allow to override command
2015-10-10 19:47:38 +08:00
b59a8664eb
fix issue #282 - emqttd_sm optimized
2015-10-10 14:32:33 +08:00
f57e6b43db
critical -> error
2015-10-10 13:36:06 +08:00
fa84a2595b
critical -> error
2015-10-10 13:30:50 +08:00
1935b414c7
issue #282 - improve sm
2015-10-10 13:12:00 +08:00
d63f043566
fix timer
2015-10-10 11:53:31 +08:00
5977c44996
fix issue #182 - etained message expiration
2015-10-10 00:04:07 +08:00
0a5d1f9e3e
{local, ?MODULE}
2015-10-10 00:01:07 +08:00
24336d006f
0.12.0
2015-10-08 14:54:31 +08:00
d5a400c308
fix issue #292 - async sub/unsub
2015-10-04 19:48:50 +08:00
78288e8088
improve keepalie
2015-10-04 19:43:58 +08:00
a6770e3727
mnesia
2015-10-01 16:10:21 +08:00
1fab8084e1
rm cli
2015-10-01 11:23:37 +08:00
354ae6f398
sort
2015-10-01 11:23:24 +08:00
14d2de3b05
MODUEL as pool name
2015-10-01 11:22:57 +08:00
e7b6778a43
rm cli
2015-10-01 11:22:33 +08:00
d7ca17b336
dump
2015-10-01 11:22:18 +08:00
af14bf9329
rm cli
2015-10-01 11:22:01 +08:00
b946f3df9b
new ctl
2015-10-01 11:21:43 +08:00
dcca96b6ae
MODULE as pool name
2015-10-01 11:21:27 +08:00
95928f6f75
rm cli
2015-10-01 11:20:41 +08:00
b539a719a8
rm cli
2015-10-01 11:20:22 +08:00
bafff792fa
useradd, userdel cli
2015-10-01 11:20:01 +08:00
d3ce7dcae1
emqttd_ctl
2015-10-01 11:19:24 +08:00
91bd0c654c
cli
2015-10-01 11:17:35 +08:00
e09148b040
cli
2015-09-30 03:06:17 +08:00
470d5644ef
priority, high
2015-09-29 17:31:10 +08:00
f15e8bc630
print ack timout
2015-09-29 12:10:55 +08:00
f57affa2b3
fix MFArgs
2015-09-29 11:27:48 +08:00
86a1f7f7d4
fix issue #264
2015-09-29 10:10:30 +08:00
dfc3194d53
env
2015-09-29 10:09:21 +08:00
23095af55f
fix issue #318
2015-09-28 21:45:44 +08:00
d7cdc477b4
fix issue #311
2015-09-24 22:38:08 +08:00
4df2e5b552
0.11.0
2015-09-22 14:51:08 +08:00
ba9534a683
fix issue #306
2015-09-21 21:11:42 +08:00
fddbdd1bb9
copy schema
2015-09-19 11:42:36 +08:00
22170b6c6d
timer:seconds
2015-09-19 09:47:17 +08:00
4c8b18389f
Merge pull request #301 from emqtt/dev-feng
...
Fix issue #284
2015-09-18 10:42:30 +08:00
7e06163587
Merge pull request #300 from emqtt/issue#292
...
Issue#292
2015-09-18 10:32:07 +08:00
74d0ef9a95
fix issue #297 - support variable
2015-09-18 10:09:10 +08:00
107c317e11
10000
2015-09-16 22:19:02 +08:00
3e899ab7a2
fix issue #284 - the stupid list_to_atom...
2015-09-16 22:11:17 +08:00
12b4bc9697
misc
2015-09-16 21:52:18 +08:00
9c53d2d3ba
session/1 api
2015-09-16 00:05:48 +08:00
ea70389cf7
ignore duplicated subscriptions
2015-09-11 14:18:30 +08:00
ac9eb43e5e
0.10.4
2015-09-11 10:50:08 +08:00
6a1159ed3f
SESSION_TIMEOUT
2015-09-10 16:17:26 +08:00
fa25d60893
fix issue#280
2015-09-10 11:18:30 +08:00
e6f358a6dd
warning
2015-08-31 13:19:59 +08:00
587cf4609a
0.10.3
2015-08-30 10:38:07 +08:00
5117d88b7a
warning
2015-08-30 10:23:26 +08:00
35bc96807e
Merge branch 'master' into dev-feng
2015-08-27 19:54:26 +08:00
07b717104b
emqttd_ws_client:subscribe/2 api
2015-08-26 21:47:21 +08:00
0f73dbf4a8
0.10.2
2015-08-25 23:44:40 +08:00
4698d040fd
fix issue #262
2015-08-25 13:49:28 +08:00
b08c39db52
stop_listeners
2015-08-24 22:20:32 +08:00
741ebf2ae1
cannot stop emqttd
2015-08-24 22:04:14 +08:00
ad1f3ca44a
add emqttd_client:subscribe/1 api. noreply/1 to hibernate
2015-08-20 19:00:01 +08:00
6d4351e8a9
priority
2015-08-18 18:59:14 +08:00
f9eeab89a2
fix gen_server2 issue, https://github.com/rabbitmq/rabbitmq-server/issues/268
2015-08-16 22:01:04 +08:00
24512a1c1d
gen_server2
2015-08-16 11:06:47 +08:00
2f1c03a469
misc fix
2015-08-16 00:36:56 +08:00
27336f9859
timestamp
2015-08-16 00:12:36 +08:00
768bc2ed1d
hibernate
2015-08-15 23:33:51 +08:00
df43214233
comment log
2015-08-15 22:31:29 +08:00
94442c270f
fix issue #212
2015-08-15 20:42:12 +08:00
aed4834aa7
comment 'inflight queue is full'
2015-08-15 11:15:36 +08:00
4c2e3e93e5
message_dropped
2015-08-14 16:00:38 +08:00
d23bf74d1e
fix issue #244
2015-08-14 12:16:41 +08:00
0232690907
Merge pull request #242 from emqtt/dev-hd
...
get_system_info
2015-08-14 10:31:45 +08:00
5d51d55533
log
2015-08-13 22:29:32 +08:00
cdf981e3c6
get_system_info
2015-08-13 19:18:56 +08:00
91ff959770
Merge pull request #241 from emqtt/issue#231
...
Issue#231
2015-08-13 17:25:52 +08:00
506dc0bd06
Add headers to mqtt_client
2015-08-13 13:01:06 +05:30
e4d45c4105
TODO
2015-08-12 00:26:28 +08:00
c4a09f97d5
fix issue #238 - emqttd_broker:unhook/2 cannot work
2015-08-12 00:26:10 +08:00
bb02ced4f2
fix issue #231
2015-08-11 00:14:07 +08:00
f94755166f
lowercase
2015-08-10 22:36:13 +08:00
3e1f8f8158
sm
2015-08-10 20:09:14 +08:00
5a612657be
session
2015-08-10 12:48:28 +08:00
049f1f1173
setstats
2015-08-10 00:28:24 +08:00
d35be39df7
session statistics
2015-08-10 00:25:11 +08:00
008f48ce43
comment
2015-08-09 12:06:02 +08:00
0f06fdd1c4
0.10.0
2015-08-08 19:33:14 +08:00
0f602d67ba
fix plugins code bug
2015-08-08 18:47:04 +08:00
c6ccacd990
plugins
2015-08-07 17:24:03 +08:00
7ba5772264
temporary
2015-08-05 15:39:29 +08:00
1a64e4e373
plugins
2015-08-04 13:21:59 +08:00
793f17f408
Merge branch 'dev' of github.com:emqtt/emqtt into dev
2015-08-04 11:40:24 +08:00
f0109c7af7
plugin
2015-08-04 11:39:30 +08:00
bf75dbf794
sync with mac air
2015-08-04 09:11:18 +08:00
dd1d48360d
rm apps
2015-08-04 09:10:54 +08:00
c0d9354932
plugins
2015-08-02 21:52:11 +08:00
48534df6c0
comment 'min_heap_size'
2015-08-01 21:00:40 +08:00
0cef1a3096
running_nodes
2015-07-30 00:15:40 +08:00
d52dcd94d5
Merge branch 'dev' of github.com:emqtt/emqtt into dev
2015-07-28 11:24:51 +08:00
b701c9ec4f
try ... catch
2015-07-28 11:22:10 +08:00
ca075f8f21
pick_worker
2015-07-28 11:05:50 +08:00
c276b6c6d1
QOS_I
2015-07-28 10:52:10 +08:00
0c5594bfcf
rm 'and comp
2015-07-27 13:48:54 +08:00
12b5722369
Merge branch 'dev' of github.com:emqtt/emqtt into dev
2015-07-27 13:42:06 +08:00
cefff9c0eb
misc
2015-07-27 13:41:47 +08:00
e370e18b19
subscribe/2
2015-07-25 14:34:44 +08:00
90b3344db0
bridges command
2015-07-25 14:34:25 +08:00
d81946b0d6
0.9.3
2015-07-25 14:34:11 +08:00
8c7d2ebe1c
0.9.3
2015-07-25 14:34:02 +08:00
98250313ab
fix issue #206
2015-07-25 14:16:36 +08:00
268fcace65
mqueue
2015-07-25 10:47:06 +08:00
c65d047fda
QOS_I
2015-07-23 16:04:21 +08:00
ffefcb6b17
Merge branch 'dev-hd' into dev
2015-07-20 08:34:05 +08:00
4278bd9db4
0.9.2
2015-07-19 09:47:29 +08:00
a43c9b3505
node api
2015-07-17 19:29:26 +08:00
cd147c453f
fix issue #196
2015-07-16 17:06:15 +08:00
5c46004c18
hooks
2015-07-16 15:55:58 +08:00
eb097c1056
fix issue #193
2015-07-14 17:55:52 +08:00
c63c74a18f
blank
2015-07-14 17:46:29 +08:00
b6121f6bcb
plain
2015-07-13 08:46:57 +08:00
da560798d1
0.9.1
2015-07-10 10:57:45 +08:00
e59232c2ab
fix issue #189 - Websocket(SSL) cannot work for emqttd_net:peername error
2015-07-10 10:48:09 +08:00
92b6bb4493
0.9.0
2015-07-09 10:17:26 +08:00
0b12082256
hibernate
2015-07-09 10:08:35 +08:00
711a875e23
misc
2015-07-08 22:12:33 +08:00
630dd4f089
https listener
2015-07-08 22:02:00 +08:00
c85617c080
distributed session
2015-07-08 18:17:48 +08:00
fcc0bb98e2
fix issue #184
2015-07-07 15:36:34 +08:00
ed81eb5a9d
'client.acked' hook
2015-07-06 15:26:30 +08:00
4f20f9691a
set_flag
2015-07-06 15:25:03 +08:00
949b70f277
subscribe, unsubscribe hooks
2015-07-06 14:07:24 +08:00
988e61708d
fix session stats
2015-07-06 00:29:08 +08:00
dcc378150d
infinity
2015-07-05 23:57:27 +08:00
d6ea474810
comment
2015-07-05 22:53:54 +08:00
4808cf31b5
vm
2015-07-05 21:00:12 +08:00
a68fa754fe
Merge branch 'dev-hd' into dev
2015-07-05 20:52:34 +08:00
1e86f7bc42
os:timestamp
2015-07-05 20:29:04 +08:00
895c9ddaed
emqttd_message:make, hooks
2015-07-05 20:18:37 +08:00
4ff7f9b2fe
global unique id
2015-07-05 20:15:53 +08:00
87dafdd7b2
client_id
2015-07-02 23:22:27 +08:00
1dcf892a69
vm
2015-06-26 15:03:00 +08:00
288973aabb
State =
2015-06-26 10:29:57 +08:00
8ea0707684
fix session
2015-06-24 22:48:35 +08:00
d09a0787ea
fix sessions
2015-06-24 22:05:00 +08:00
0f68186472
mqueue test
2015-06-24 09:26:22 +08:00
eeee584fef
add 'clientid'
2015-06-24 03:07:59 +08:00
b4080a0adf
ts
2015-06-24 02:51:56 +08:00
82bd645d7a
fix session issue
2015-06-24 01:56:44 +08:00
d0429f56e7
fix 'loads/0' export
2015-06-24 00:38:15 +08:00
89c939b321
{subscribe, TopicTable}
2015-06-24 00:37:58 +08:00
34fc0fb157
now_to_secs
2015-06-24 00:37:41 +08:00
2ff78d7fc6
alarm
2015-06-24 00:37:02 +08:00
7e97e39bd1
etc/plugins.config
2015-06-23 12:46:51 +08:00
3e5675cc71
ipaddress
2015-06-23 12:20:41 +08:00
8702ab838c
0.9 project structure
2015-06-22 16:18:33 +08:00
3a6ed9a876
0.2 project structure
2014-12-06 19:12:29 +08:00
109e98d80c
change heap size
2014-12-02 22:53:29 +08:00
c12a0b236e
add monitor
2014-12-01 22:54:48 +08:00
acc491c799
uupdate go timeout
2014-12-01 17:15:02 +08:00
34bcd2b2db
test
2014-08-19 16:05:21 +08:00
13bf396306
fix issue#18
2013-11-05 00:21:30 +08:00
1f1099e667
add appmon
2013-10-31 17:36:40 +08:00
3e3dfe3fa2
fix client
2013-09-17 11:25:27 +08:00
fd711f3fbc
trie delete
2013-08-23 14:38:28 +08:00
570ca1aa78
fix issue#17
2013-07-16 14:39:38 +08:00
9bdbb84ed2
refactor header file
2013-06-28 11:01:23 +08:00
860532fc68
fix unsubscribe 'error topics'
2013-03-18 15:18:25 +08:00
3626979e31
0.1.5 bug fix
2013-01-05 16:21:37 +08:00
3979c83550
vsn 0.1.4
2013-01-04 16:36:03 +08:00
ba5e21278e
fix qos_2 subscribe
2013-01-04 16:29:35 +08:00
97d27e2456
fix qos_2 bugs
2013-01-04 13:24:18 +08:00
8b85ce4278
add publish/1 api
2013-01-03 21:03:00 +08:00
2c8bb114f9
fix qos_2 message flow
2013-01-03 20:30:07 +08:00
31c687f26c
support trie topic structure
2013-01-01 20:16:02 +08:00
6d795c7273
add license
2012-12-27 21:55:41 +08:00
dbad1cf920
fix cluster
2012-12-27 16:51:32 +08:00
58b1e258c1
add folder
2012-12-27 16:42:59 +08:00
52cca0a908
vsn 0.1.2
2012-12-26 15:38:16 +08:00
69b9e74a94
use ?INFO to print log
2012-12-26 15:25:27 +08:00
e7ba96b263
fix ctl api
2012-12-26 14:36:39 +08:00
ea1e3c59a0
vsn 0.1.1
2012-12-24 17:16:37 +08:00
76169eb446
support topic cluster
2012-12-24 16:59:12 +08:00
c082cbb27b
fix topic record
2012-12-24 11:59:02 +08:00
cd1e2c73d2
support client registry
2012-12-23 17:55:10 +08:00
8fa63244bb
fix issue#3 'PUBLISH' RETAIN
2012-12-23 16:53:38 +08:00
7117d03a09
support keep alive
2012-12-23 16:14:02 +08:00
a8e860b07d
fix .app.src
2012-12-22 18:03:28 +08:00
c1b9449c53
fix sub/pub
2012-12-22 17:35:28 +08:00
425bc2157e
add auth support
2012-12-22 16:42:32 +08:00
87db1acf2b
rm tmp
2012-12-22 14:28:29 +08:00
92ce6ef539
merge emqtt_processor to emqtt_client
2012-12-22 14:28:04 +08:00
0953344e06
fix status
2012-12-21 17:36:32 +08:00
efc1d9f424
add bin/ and some files
2012-12-21 17:33:21 +08:00
6245fb4aa9
first workable
2012-12-21 13:24:48 +08:00
fcb5ac6df3
add mqtt frame
2012-12-21 11:30:35 +08:00
0fabf9feb2
tcp options
2012-12-20 17:35:02 +08:00
cc67e10e69
fix client
2012-12-20 16:44:57 +08:00
a77bbf33e2
first workable
2012-12-20 16:30:51 +08:00
bac534c8c8
fix router
2012-12-19 13:45:04 +08:00
cb04c9c7e5
add file
2012-12-19 13:42:03 +08:00
Feng Lee