b0f082ebe0
to_hexstr/1, from_hexstr/1
2016-08-23 10:13:13 +08:00
a0e2d2981a
merge mqtt-sn
2016-08-22 17:41:54 +08:00
a1ed02499c
mqtt_topic
2016-08-21 16:21:45 +08:00
0816ec9966
emqttd_app eunit
2016-08-21 14:09:00 +08:00
7206e18621
mqtt_topic
2016-08-21 13:52:53 +08:00
1eaa5bdfa6
tab topic
2016-08-21 13:46:11 +08:00
314aaf536f
add export
2016-08-21 13:13:17 +08:00
8f54572f93
run_hooks client.subscribe.after
2016-08-18 15:54:02 +08:00
354ab5ad21
msgid -> id
2016-08-18 10:57:00 +08:00
6beb6bbbe4
os:timestamp
2016-08-18 10:25:20 +08:00
f2f5f251d7
improve the design of retainer
2016-08-18 08:09:43 +08:00
2b45dbf09f
fix 'undefined' msgid
2016-08-17 13:46:32 +08:00
6d5ce1f584
Merge branch 'emq20' of github.com:emqtt/emqttd into emq20
2016-08-17 12:35:59 +08:00
d72c7ad07c
fix format
2016-08-17 12:35:26 +08:00
b59a1d7547
sender
2016-08-17 08:49:45 +08:00
01cf8b8562
Username
2016-08-16 15:49:00 +08:00
595c0f2d5a
dispatch
2016-08-16 15:38:38 +08:00
ef8006bc89
fix rewrite
2016-08-16 15:23:17 +08:00
e2246c7406
reg_session
2016-08-16 14:43:16 +08:00
d0be556f33
2.0 - improve design of session and hook
2016-08-16 14:29:39 +08:00
c5e88ab1a4
emqttd_ctl eunit
2016-08-15 15:36:52 +08:00
8c1af879d3
emqttd_app eunit
2016-08-15 11:29:12 +08:00
f166143cd0
Don't register name for pool_sup
2016-08-13 12:21:18 +08:00
d8aa7d9cfa
emqttd_bridge_sup_sup
2016-08-13 11:24:06 +08:00
8ca3430e39
improve the design of bridge
2016-08-13 11:03:14 +08:00
bc5cfb4b36
bridge sup
2016-08-13 11:02:39 +08:00
1266b4e860
ack qos
2016-08-12 22:39:13 +08:00
0a967df15a
do_subscribe_/4, do_unsubscribe_/3
2016-08-12 22:23:29 +08:00
6e64686f77
pass test cases first
2016-08-12 16:49:50 +08:00
dd9217bf73
fix cli
2016-08-12 16:26:36 +08:00
9a4c44913e
commen tests
2016-08-12 12:59:03 +08:00
c86aa94ae7
mqtt_subscriber
2016-08-10 22:41:06 +08:00
8a0a7978dd
presence
2016-08-10 22:30:02 +08:00
e2dab894af
emqttd_server:publish/1
2016-08-10 22:22:12 +08:00
0d16f766c3
setstats for mqtt_subscriber
2016-08-10 21:54:02 +08:00
417cb3620d
mqtt_subscriber
2016-08-10 21:50:28 +08:00
d6041395ef
mqtt_session and mqtt_local_session
2016-08-10 21:45:37 +08:00
c67a30bf7b
mqtt_subproperty
2016-08-10 21:38:00 +08:00
38daaa2f5c
server -> pubsub -> router
2016-08-10 21:29:55 +08:00
91e96e738d
emqttd_cm:reg/1, emqttd_cm:unreg/1
2016-08-10 16:40:36 +08:00
766f74692d
mqtt_local_session
2016-08-10 16:36:09 +08:00
162b7ec229
mqtt_pubsub, mqtt_subscription, mqtt_subscriber
2016-08-10 15:41:10 +08:00
6686139bc6
mqtt_trie, mqtt_trie_node
2016-08-10 15:04:26 +08:00
15be2037f3
async_unsubscribe -> unsubscribe
2016-08-10 14:08:46 +08:00
b92231047c
subscriber_down/1
2016-08-10 14:02:13 +08:00
bf8730d12d
{noreply, State}
2016-08-10 12:26:51 +08:00
bba8066639
Dispatcher
2016-08-10 12:18:55 +08:00
078c39232b
dispatcher
2016-08-10 12:12:25 +08:00
33472a7f6e
pubsub and dispatcher
2016-08-10 12:11:52 +08:00
af6c779631
improve the pubsub design
2016-08-09 18:45:47 +08:00
4c4d9a718c
emqttd_router:dump/0
2016-08-08 17:41:48 +08:00
317ce3cfdf
ok
2016-08-08 14:58:49 +08:00
28be1e2a00
Add dispatch/3
2016-08-08 14:34:11 +08:00
bc72e33056
PubSub:init_tabs
2016-08-08 14:14:54 +08:00
b3a48b937f
pubsub_adapter
2016-08-08 14:06:52 +08:00
8b6cc4d5f8
don't create topics
2016-08-08 14:01:49 +08:00
226933018a
improve the design of pubsub and router
2016-08-08 13:49:52 +08:00
e73df7f54f
proc monitor module
2016-08-08 13:46:15 +08:00
37bd5465bd
support local route
2016-08-07 18:09:07 +08:00
285421f073
rm emqttd_backend.erl
2016-08-01 15:07:38 +08:00
f998d2a41d
fix CT errors
2016-07-23 11:10:55 +08:00
3c33bdddc7
list_to_atom
2016-07-22 11:43:40 +08:00
67637408fc
string:tokens/2
2016-07-22 11:41:11 +08:00
3f9de8c073
fix plugins
2016-07-22 11:38:48 +08:00
1bcc2272b5
fix compile warning
2016-07-21 18:29:31 +08:00
3e42f57bc6
2.0 - emqttd:conf/1 to read config
2016-07-21 17:52:08 +08:00
68910aa403
2.0 - gen_conf, gen_logger applications
2016-07-21 17:51:28 +08:00
9555b0bf05
2.0 - support 'cache_acl' option
2016-07-21 17:51:02 +08:00
0dbbe7d0df
2.0 - read config from etc/emqttd.conf
2016-07-21 17:23:34 +08:00
1602b44267
2.0 - gen_conf:value/2 to read config
2016-07-21 17:19:08 +08:00
2370e7dfcb
2.0 - replace 'now/0' with 'erlang:monotonic_time/0'
2016-07-21 17:18:27 +08:00
710890dd22
relx
2016-07-21 09:31:14 +08:00
2e200f253f
2.0 - erlang.mk to replace rebar
2016-07-19 17:46:05 +08:00
03d6710b60
gen_conf to improve the configuration of emqttd broker
2016-07-19 16:49:30 +08:00
ca44fd4031
Merge branch 'master' into plus
2016-07-16 21:56:37 +08:00
61b2ab48ad
merge emq10
2016-07-16 21:55:02 +08:00
9f509c3d13
optimize the procedures that retrieve the Broker version and Borker description in the tick timer
2016-07-15 21:45:58 +08:00
a362b96b6b
add 'bin/emqttd_ctl users list' command
2016-07-06 15:23:45 +08:00
3a43d2b41f
WSLOG
2016-06-30 23:24:02 +08:00
c926964b8c
Merge branch 'master' into emq10
2016-06-30 14:48:07 +08:00
686574913c
fix issue #561 - websocket client's process may leak when no mqtt packets received
2016-06-30 14:40:07 +08:00
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
Feng Lee