Commit Graph

620 Commits

Author SHA1 Message Date
Feng c0c79e8171 rm gen_conf and emqttd_conf 2016-10-11 09:09:29 +08:00
Feng Lee 99632bfbb6 rm gen_conf 2016-10-09 09:35:57 +08:00
Feng 2e9bc16136 emqttd_plugins:init/0 2016-10-02 14:36:54 +08:00
Feng daa87206a7 random 2016-10-01 09:43:21 +08:00
Feng 6b3d67c515 fix random:seed/1 warning 2016-09-30 16:13:50 +08:00
Feng f510ab894f remove is_superuser/2 callback 2016-09-30 10:23:04 +08:00
Feng 8d48e8d2e2 Support 'is_superuser/2 callback 2016-09-28 22:45:20 +08:00
Feng d0218deb88 Add hooks: session.created, session.terminated 2016-09-28 22:43:58 +08:00
Feng 66ca65733a emqttd:run_hooks/2, emqttd_hook:run/2 2016-09-23 15:29:12 +08:00
Feng 1bb1799d34 local subscription, shared subscription 2016-09-18 14:08:57 +08:00
Feng 7d9ad96021 refactor emqttd_conf 2016-09-09 22:52:17 +08:00
turtled 61d8b2d907 fixed emqttd_ctl bridges list error 2016-09-09 21:49:57 +08:00
Feng Lee 7e41bc9091 improve conf design 2016-09-09 20:30:00 +08:00
Feng Lee edb45d7029 retained_message -> mqtt_retained 2016-09-09 19:38:42 +08:00
Feng Lee 5eda6c9dd2 rewrite_subscribe/4, rewrite_unsubscribe/4 2016-09-09 17:37:25 +08:00
Feng Lee 66c84aef00 '' -> '%u', '' -> '%c' 2016-09-09 17:00:12 +08:00
Feng Lee 6ceb1c6718 Fix subscribe, unsubscribe 2016-09-09 16:34:29 +08:00
Feng bd61ddb03c map() 2016-09-09 10:48:39 +08:00
Feng 5d10a1c224 Merge branch 'emq20' of github.com:emqtt/emqttd into emq20 2016-09-09 10:36:22 +08:00
huangdan a677e1628d rename mqtt_topic 2016-09-08 15:40:35 +08:00
Feng a16802d018 session.subscribed, session.unsubscribed hooks and retainer module 2016-09-08 09:10:45 +08:00
Ali Farhadi 49258f4a0c Fixing issues in cluster mode. 2016-09-07 15:07:06 +04:30
Ali Farhadi 7a295f614f Send ClientId, Username as a Tuple in unsubscribe hook 2016-09-03 11:56:42 +04:30
Ali Farhadi 177ae6a71b Fix unmatching args in mod_rewrite unsubscribe hook 2016-09-03 11:56:28 +04:30
Feng aab2bddeda fix issue #671 - fix clientid trace 2016-09-02 09:11:55 +08:00
Feng 10e9abfdec fix issue #671 - ~p 2016-09-02 08:39:34 +08:00
Feng 19fd92b41b Send Packet... 2016-08-29 13:57:12 +08:00
Feng d61d2605ad base62 2016-08-27 15:50:49 +08:00
Feng dbed5b914a base62 2016-08-27 15:44:22 +08:00
Feng Lee b0f082ebe0 to_hexstr/1, from_hexstr/1 2016-08-23 10:13:13 +08:00
Feng Lee a0e2d2981a merge mqtt-sn 2016-08-22 17:41:54 +08:00
Feng Lee a1ed02499c mqtt_topic 2016-08-21 16:21:45 +08:00
huangdan 0816ec9966 emqttd_app eunit 2016-08-21 14:09:00 +08:00
huangdan 7206e18621 mqtt_topic 2016-08-21 13:52:53 +08:00
huangdan 1eaa5bdfa6 tab topic 2016-08-21 13:46:11 +08:00
huangdan 314aaf536f add export 2016-08-21 13:13:17 +08:00
Feng Lee 8f54572f93 run_hooks client.subscribe.after 2016-08-18 15:54:02 +08:00
Feng Lee 354ab5ad21 msgid -> id 2016-08-18 10:57:00 +08:00
Feng Lee 6beb6bbbe4 os:timestamp 2016-08-18 10:25:20 +08:00
Feng Lee f2f5f251d7 improve the design of retainer 2016-08-18 08:09:43 +08:00
Feng Lee 2b45dbf09f fix 'undefined' msgid 2016-08-17 13:46:32 +08:00
Feng Lee 6d5ce1f584 Merge branch 'emq20' of github.com:emqtt/emqttd into emq20 2016-08-17 12:35:59 +08:00
Feng Lee d72c7ad07c fix format 2016-08-17 12:35:26 +08:00
Feng b59a1d7547 sender 2016-08-17 08:49:45 +08:00
Feng Lee 01cf8b8562 Username 2016-08-16 15:49:00 +08:00
Feng Lee 595c0f2d5a dispatch 2016-08-16 15:38:38 +08:00
Feng Lee ef8006bc89 fix rewrite 2016-08-16 15:23:17 +08:00
Feng Lee e2246c7406 reg_session 2016-08-16 14:43:16 +08:00
Feng Lee d0be556f33 2.0 - improve design of session and hook 2016-08-16 14:29:39 +08:00
huangdan c5e88ab1a4 emqttd_ctl eunit 2016-08-15 15:36:52 +08:00
huangdan 8c1af879d3 emqttd_app eunit 2016-08-15 11:29:12 +08:00
Feng Lee f166143cd0 Don't register name for pool_sup 2016-08-13 12:21:18 +08:00
Feng Lee d8aa7d9cfa emqttd_bridge_sup_sup 2016-08-13 11:24:06 +08:00
Feng Lee 8ca3430e39 improve the design of bridge 2016-08-13 11:03:14 +08:00
Feng Lee bc5cfb4b36 bridge sup 2016-08-13 11:02:39 +08:00
Feng Lee 1266b4e860 ack qos 2016-08-12 22:39:13 +08:00
Feng Lee 0a967df15a do_subscribe_/4, do_unsubscribe_/3 2016-08-12 22:23:29 +08:00
Feng Lee 6e64686f77 pass test cases first 2016-08-12 16:49:50 +08:00
Feng dd9217bf73 fix cli 2016-08-12 16:26:36 +08:00
Feng Lee 9a4c44913e commen tests 2016-08-12 12:59:03 +08:00
Feng Lee c86aa94ae7 mqtt_subscriber 2016-08-10 22:41:06 +08:00
Feng Lee 8a0a7978dd presence 2016-08-10 22:30:02 +08:00
Feng Lee e2dab894af emqttd_server:publish/1 2016-08-10 22:22:12 +08:00
Feng Lee 0d16f766c3 setstats for mqtt_subscriber 2016-08-10 21:54:02 +08:00
Feng Lee 417cb3620d mqtt_subscriber 2016-08-10 21:50:28 +08:00
Feng Lee d6041395ef mqtt_session and mqtt_local_session 2016-08-10 21:45:37 +08:00
Feng Lee c67a30bf7b mqtt_subproperty 2016-08-10 21:38:00 +08:00
Feng Lee 38daaa2f5c server -> pubsub -> router 2016-08-10 21:29:55 +08:00
Feng Lee 91e96e738d emqttd_cm:reg/1, emqttd_cm:unreg/1 2016-08-10 16:40:36 +08:00
Feng Lee 766f74692d mqtt_local_session 2016-08-10 16:36:09 +08:00
Feng Lee 162b7ec229 mqtt_pubsub, mqtt_subscription, mqtt_subscriber 2016-08-10 15:41:10 +08:00
Feng Lee 6686139bc6 mqtt_trie, mqtt_trie_node 2016-08-10 15:04:26 +08:00
Feng Lee 15be2037f3 async_unsubscribe -> unsubscribe 2016-08-10 14:08:46 +08:00
Feng Lee b92231047c subscriber_down/1 2016-08-10 14:02:13 +08:00
Feng Lee bf8730d12d {noreply, State} 2016-08-10 12:26:51 +08:00
Feng Lee bba8066639 Dispatcher 2016-08-10 12:18:55 +08:00
Feng Lee 078c39232b dispatcher 2016-08-10 12:12:25 +08:00
Feng Lee 33472a7f6e pubsub and dispatcher 2016-08-10 12:11:52 +08:00
Feng af6c779631 improve the pubsub design 2016-08-09 18:45:47 +08:00
Feng Lee 4c4d9a718c emqttd_router:dump/0 2016-08-08 17:41:48 +08:00
Feng Lee 317ce3cfdf ok 2016-08-08 14:58:49 +08:00
Feng Lee 28be1e2a00 Add dispatch/3 2016-08-08 14:34:11 +08:00
Feng bc72e33056 PubSub:init_tabs 2016-08-08 14:14:54 +08:00
Feng b3a48b937f pubsub_adapter 2016-08-08 14:06:52 +08:00
Feng 8b6cc4d5f8 don't create topics 2016-08-08 14:01:49 +08:00
Feng 226933018a improve the design of pubsub and router 2016-08-08 13:49:52 +08:00
Feng e73df7f54f proc monitor module 2016-08-08 13:46:15 +08:00
Feng 37bd5465bd support local route 2016-08-07 18:09:07 +08:00
Feng 285421f073 rm emqttd_backend.erl 2016-08-01 15:07:38 +08:00
Feng f998d2a41d fix CT errors 2016-07-23 11:10:55 +08:00
Feng Lee 3c33bdddc7 list_to_atom 2016-07-22 11:43:40 +08:00
Feng Lee 67637408fc string:tokens/2 2016-07-22 11:41:11 +08:00
Feng Lee 3f9de8c073 fix plugins 2016-07-22 11:38:48 +08:00
Feng Lee 1bcc2272b5 fix compile warning 2016-07-21 18:29:31 +08:00
Feng Lee 3e42f57bc6 2.0 - emqttd:conf/1 to read config 2016-07-21 17:52:08 +08:00
Feng Lee 68910aa403 2.0 - gen_conf, gen_logger applications 2016-07-21 17:51:28 +08:00
Feng Lee 9555b0bf05 2.0 - support 'cache_acl' option 2016-07-21 17:51:02 +08:00
Feng Lee 0dbbe7d0df 2.0 - read config from etc/emqttd.conf 2016-07-21 17:23:34 +08:00
Feng Lee 1602b44267 2.0 - gen_conf:value/2 to read config 2016-07-21 17:19:08 +08:00
Feng Lee 2370e7dfcb 2.0 - replace 'now/0' with 'erlang:monotonic_time/0' 2016-07-21 17:18:27 +08:00