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

2210 Commits

Author SHA1 Message Date
Feng 38fb211719 Merge branch 'master' of github.com:emqtt/emqttd 2015-11-06 12:30:27 +08:00
Feng d227ba3ced warning 2015-11-06 12:30:07 +08:00
Feng 4e0220ae81 ok 2015-11-05 12:40:06 +08:00
Feng 22889f552c fix issue #163 - Protocol Compliant - Session Present Flag 2015-11-05 12:29:29 +08:00
Feng 8491467bbb support 'and', 'or' 2015-11-04 21:42:17 +08:00
Feng d09721301e conflict 2015-11-04 10:22:49 +08:00
Feng 9bad2bf65b support Seq 2015-11-03 12:52:27 +08:00
Feng ea564ec8ef mod 2015-11-02 20:34:23 +08:00
Feng ecc0f052ef reply 2015-11-02 15:51:34 +08:00
Feng cff4ca0296 vsn 2015-11-02 15:51:24 +08:00
Feng 3c69d1a5c1 fix log 2015-11-02 15:00:43 +08:00
Feng 83d4801fe8 disc_copies 2015-11-01 20:45:13 +08:00
Feng 4b26291cb9 client(State) 2015-11-01 20:44:21 +08:00
Feng c7f0e33674 rate limit 2015-11-01 16:03:32 +08:00
Feng cf95c5e1b9 0.13 refactor 2015-10-31 18:43:04 +08:00
Feng 3f41a6c241 peername 2015-10-31 15:08:25 +08:00
Feng f9027ed1f4 fix issue #367 - Fix the order of emqttd_app:start_server/1 2015-10-31 15:07:50 +08:00
Feng b9962d697c 0.13.0 2015-10-30 21:23:17 +08:00
Feng 4ed62d018e refactor log 2015-10-30 21:20:37 +08:00
Feng Lee 19930b6382 refactor protocol 2015-10-30 18:00:23 +08:00
Feng f6636a9783 refactor client 2015-10-30 16:03:25 +08:00
Feng f4cf90ae91 refactor client 2015-10-30 16:00:11 +08:00
Feng Lee 565c8abb3a improve suback 2015-10-26 16:30:39 +08:00
Feng 47710c36aa port_command 2015-10-26 09:25:57 +08:00
Feng 976c7653f3 use esockd_rate_limiter 2015-10-26 09:25:40 +08:00
Feng f58f42196a 0.12.4 2015-10-26 09:21:24 +08:00
Feng 2af91ea140 link with client 2015-10-26 09:21:03 +08:00
Feng fb9f1bf8e4 rate_limit 2015-10-26 09:20:13 +08:00
Feng 59ca283eb0 gen_server 2015-10-23 18:06:35 +08:00
Feng fd7276c587 0.12.3 2015-10-22 10:31:29 +08:00
Feng 8bddc3e327 comment binary 2015-10-22 10:31:03 +08:00
Feng 52d63125d3 improve log and fix issue #353 2015-10-21 21:36:56 +08:00
Feng 86ea9c844f fix issue #350 2015-10-21 21:18:36 +08:00
Feng 7530bfb5fa ets:insert 2015-10-19 09:45:36 +08:00
Feng 6faf488701 ets:insert 2015-10-19 09:45:31 +08:00
Feng 67ebff26ce 0.12.2 2015-10-16 15:07:25 +08:00
Feng a35d51ea24 fix issue #346 2015-10-16 14:58:51 +08:00
Feng fae3e1e32f AckFun 2015-10-15 18:59:51 +08:00
Feng Lee 221124d7b2 fix issue #266 - will not count publish 2015-10-14 19:07:41 +08:00
Feng Lee e3b5c6be4e PUBLISH_PACKET 2015-10-14 18:56:43 +08:00
Feng 3dd42b65cf /status 2015-10-13 23:03:02 +08:00
Feng a16e527975 0.12.1 refactor 2015-10-13 21:09:13 +08:00
Feng 05ff1ab002 gen_event 2015-10-13 21:08:56 +08:00
Feng ebf203a931 refactor metrics 2015-10-13 21:05:11 +08:00
Feng 6a66ca90b1 concat 2015-10-13 21:04:15 +08:00
Feng 5daeac083c spec 2015-10-13 21:03:25 +08:00
Feng 43523f2a1c received/sent metrics 2015-10-13 21:03:01 +08:00
Feng d3e39ae9a3 src/emqttd_mod_rewrite.erl 2015-10-13 21:01:53 +08:00
Feng a055a0a0c8 IS_PUBSUB 2015-10-13 20:56:10 +08:00
Feng 192dc85304 id 2015-10-13 20:55:33 +08:00
Feng 063f59f846 fix process_info 2015-10-12 21:07:05 +08:00
Feng d4a434176a sysmon 2015-10-12 21:06:47 +08:00
Feng 6209d47aae name 2015-10-12 21:06:18 +08:00
Feng 4825591565 name 2015-10-12 21:06:01 +08:00
Feng deaf220343 sysmon 2015-10-12 21:05:37 +08:00
Feng 47e3e826dc 0.12.1 2015-10-12 21:03:01 +08:00
Feng Lee 20cfc2754c broker 2015-10-11 21:10:47 +08:00
Feng 8eb54cc2c3 fix issue #68 - /# topics will not match #, +/# 2015-10-11 15:27:56 +08:00
Feng 87b5245494 rm space 2015-10-11 04:02:33 +08:00
Feng 13001396de cli 2015-10-11 03:03:07 +08:00
Feng b9b75fdb65 add 'dist' module 2015-10-11 02:48:32 +08:00
Feng 6bc3e70f46 export node_name/1 2015-10-10 20:12:24 +08:00
Feng 7af13af848 warning 2015-10-10 19:56:43 +08:00
Feng aad1f3547f allow to override command 2015-10-10 19:47:38 +08:00
Feng Lee b59a8664eb fix issue #282 - emqttd_sm optimized 2015-10-10 14:32:33 +08:00
Feng Lee f57e6b43db critical -> error 2015-10-10 13:36:06 +08:00
Feng Lee fa84a2595b critical -> error 2015-10-10 13:30:50 +08:00
Feng Lee 1935b414c7 issue #282 - improve sm 2015-10-10 13:12:00 +08:00
Feng Lee d63f043566 fix timer 2015-10-10 11:53:31 +08:00
Feng 5977c44996 fix issue #182 - etained message expiration 2015-10-10 00:04:07 +08:00
Feng 0a5d1f9e3e {local, ?MODULE} 2015-10-10 00:01:07 +08:00
Feng 24336d006f 0.12.0 2015-10-08 14:54:31 +08:00
Feng d5a400c308 fix issue #292 - async sub/unsub 2015-10-04 19:48:50 +08:00
Feng 78288e8088 improve keepalie 2015-10-04 19:43:58 +08:00
Feng a6770e3727 mnesia 2015-10-01 16:10:21 +08:00
Feng 1fab8084e1 rm cli 2015-10-01 11:23:37 +08:00
Feng 354ae6f398 sort 2015-10-01 11:23:24 +08:00
Feng 14d2de3b05 MODUEL as pool name 2015-10-01 11:22:57 +08:00
Feng e7b6778a43 rm cli 2015-10-01 11:22:33 +08:00
Feng d7ca17b336 dump 2015-10-01 11:22:18 +08:00
Feng af14bf9329 rm cli 2015-10-01 11:22:01 +08:00
Feng b946f3df9b new ctl 2015-10-01 11:21:43 +08:00
Feng dcca96b6ae MODULE as pool name 2015-10-01 11:21:27 +08:00
Feng 95928f6f75 rm cli 2015-10-01 11:20:41 +08:00
Feng b539a719a8 rm cli 2015-10-01 11:20:22 +08:00
Feng bafff792fa useradd, userdel cli 2015-10-01 11:20:01 +08:00
Feng d3ce7dcae1 emqttd_ctl 2015-10-01 11:19:24 +08:00
Feng 91bd0c654c cli 2015-10-01 11:17:35 +08:00
Feng Lee e09148b040 cli 2015-09-30 03:06:17 +08:00
Feng Lee 470d5644ef priority, high 2015-09-29 17:31:10 +08:00
Feng Lee f15e8bc630 print ack timout 2015-09-29 12:10:55 +08:00
Feng Lee f57affa2b3 fix MFArgs 2015-09-29 11:27:48 +08:00
Feng 86a1f7f7d4 fix issue #264 2015-09-29 10:10:30 +08:00
Feng dfc3194d53 env 2015-09-29 10:09:21 +08:00
Feng Lee 23095af55f fix issue #318 2015-09-28 21:45:44 +08:00
Feng Lee d7cdc477b4 fix issue #311 2015-09-24 22:38:08 +08:00
Feng Lee 4df2e5b552 0.11.0 2015-09-22 14:51:08 +08:00
Feng Lee ba9534a683 fix issue #306 2015-09-21 21:11:42 +08:00
Feng Lee fddbdd1bb9 copy schema 2015-09-19 11:42:36 +08:00
Feng Lee 22170b6c6d timer:seconds 2015-09-19 09:47:17 +08:00
Feng Lee 4c8b18389f Merge pull request #301 from emqtt/dev-feng 
Fix issue #284
 2015-09-18 10:42:30 +08:00
Feng Lee 7e06163587 Merge pull request #300 from emqtt/issue#292 
Issue#292
 2015-09-18 10:32:07 +08:00
Feng 74d0ef9a95 fix issue #297 - support variable 2015-09-18 10:09:10 +08:00
Feng Lee 107c317e11 10000 2015-09-16 22:19:02 +08:00
Feng Lee 3e899ab7a2 fix issue #284 - the stupid list_to_atom... 2015-09-16 22:11:17 +08:00
Feng Lee 12b4bc9697 misc 2015-09-16 21:52:18 +08:00
Feng 9c53d2d3ba session/1 api 2015-09-16 00:05:48 +08:00
Feng ea70389cf7 ignore duplicated subscriptions 2015-09-11 14:18:30 +08:00
Feng ac9eb43e5e 0.10.4 2015-09-11 10:50:08 +08:00
Feng 6a1159ed3f SESSION_TIMEOUT 2015-09-10 16:17:26 +08:00
Feng fa25d60893 fix issue#280 2015-09-10 11:18:30 +08:00
Feng e6f358a6dd warning 2015-08-31 13:19:59 +08:00
Feng Lee 587cf4609a 0.10.3 2015-08-30 10:38:07 +08:00
Feng Lee 5117d88b7a warning 2015-08-30 10:23:26 +08:00
Feng 35bc96807e Merge branch 'master' into dev-feng 2015-08-27 19:54:26 +08:00
Feng 07b717104b emqttd_ws_client:subscribe/2 api 2015-08-26 21:47:21 +08:00
Feng 0f73dbf4a8 0.10.2 2015-08-25 23:44:40 +08:00
Feng 4698d040fd fix issue #262 2015-08-25 13:49:28 +08:00
Feng b08c39db52 stop_listeners 2015-08-24 22:20:32 +08:00
Feng 741ebf2ae1 cannot stop emqttd 2015-08-24 22:04:14 +08:00
Feng Lee ad1f3ca44a add emqttd_client:subscribe/1 api. noreply/1 to hibernate 2015-08-20 19:00:01 +08:00
Feng Lee 6d4351e8a9 priority 2015-08-18 18:59:14 +08:00
Feng Lee f9eeab89a2 fix gen_server2 issue, https://github.com/rabbitmq/rabbitmq-server/issues/268 2015-08-16 22:01:04 +08:00
Feng Lee 24512a1c1d gen_server2 2015-08-16 11:06:47 +08:00
Feng 2f1c03a469 misc fix 2015-08-16 00:36:56 +08:00
Feng Lee 27336f9859 timestamp 2015-08-16 00:12:36 +08:00
Feng Lee 768bc2ed1d hibernate 2015-08-15 23:33:51 +08:00
Feng Lee df43214233 comment log 2015-08-15 22:31:29 +08:00
Feng Lee 94442c270f fix issue #212 2015-08-15 20:42:12 +08:00
Feng Lee aed4834aa7 comment 'inflight queue is full' 2015-08-15 11:15:36 +08:00
Feng Lee 4c2e3e93e5 message_dropped 2015-08-14 16:00:38 +08:00
Feng Lee d23bf74d1e fix issue #244 2015-08-14 12:16:41 +08:00
Feng Lee 0232690907 Merge pull request #242 from emqtt/dev-hd 
get_system_info
 2015-08-14 10:31:45 +08:00
Feng Lee 5d51d55533 log 2015-08-13 22:29:32 +08:00
huangdan cdf981e3c6 get_system_info 2015-08-13 19:18:56 +08:00
Feng Lee 91ff959770 Merge pull request #241 from emqtt/issue#231 
Issue#231
 2015-08-13 17:25:52 +08:00
J Phani Mahesh 506dc0bd06 Add headers to mqtt_client 2015-08-13 13:01:06 +05:30
Feng Lee e4d45c4105 TODO 2015-08-12 00:26:28 +08:00
Feng Lee c4a09f97d5 fix issue #238 - emqttd_broker:unhook/2 cannot work 2015-08-12 00:26:10 +08:00
Feng bb02ced4f2 fix issue #231 2015-08-11 00:14:07 +08:00
Feng Lee f94755166f lowercase 2015-08-10 22:36:13 +08:00
Feng Lee 3e1f8f8158 sm 2015-08-10 20:09:14 +08:00
Feng Lee 5a612657be session 2015-08-10 12:48:28 +08:00
Feng 049f1f1173 setstats 2015-08-10 00:28:24 +08:00
Feng d35be39df7 session statistics 2015-08-10 00:25:11 +08:00
Feng Lee 008f48ce43 comment 2015-08-09 12:06:02 +08:00
Feng Lee 0f06fdd1c4 0.10.0 2015-08-08 19:33:14 +08:00
Feng Lee 0f602d67ba fix plugins code bug 2015-08-08 18:47:04 +08:00
Feng Lee c6ccacd990 plugins 2015-08-07 17:24:03 +08:00
Feng Lee 7ba5772264 temporary 2015-08-05 15:39:29 +08:00
Feng 1a64e4e373 plugins 2015-08-04 13:21:59 +08:00
Feng 793f17f408 Merge branch 'dev' of github.com:emqtt/emqtt into dev 2015-08-04 11:40:24 +08:00
Feng f0109c7af7 plugin 2015-08-04 11:39:30 +08:00
Feng Lee bf75dbf794 sync with mac air 2015-08-04 09:11:18 +08:00
Feng Lee dd1d48360d rm apps 2015-08-04 09:10:54 +08:00
Feng Lee c0d9354932 plugins 2015-08-02 21:52:11 +08:00
Feng Lee 48534df6c0 comment 'min_heap_size' 2015-08-01 21:00:40 +08:00
Feng Lee 0cef1a3096 running_nodes 2015-07-30 00:15:40 +08:00
Feng Lee d52dcd94d5 Merge branch 'dev' of github.com:emqtt/emqtt into dev 2015-07-28 11:24:51 +08:00
Feng Lee b701c9ec4f try ... catch 2015-07-28 11:22:10 +08:00
Feng ca075f8f21 pick_worker 2015-07-28 11:05:50 +08:00
Feng c276b6c6d1 QOS_I 2015-07-28 10:52:10 +08:00
Feng 0c5594bfcf rm 'and comp 2015-07-27 13:48:54 +08:00
Feng 12b5722369 Merge branch 'dev' of github.com:emqtt/emqtt into dev 2015-07-27 13:42:06 +08:00
Feng cefff9c0eb misc 2015-07-27 13:41:47 +08:00
Feng Lee e370e18b19 subscribe/2 2015-07-25 14:34:44 +08:00
Feng Lee 90b3344db0 bridges command 2015-07-25 14:34:25 +08:00
Feng Lee d81946b0d6 0.9.3 2015-07-25 14:34:11 +08:00
Feng Lee 8c7d2ebe1c 0.9.3 2015-07-25 14:34:02 +08:00
Feng Lee 98250313ab fix issue #206 2015-07-25 14:16:36 +08:00
Feng Lee 268fcace65 mqueue 2015-07-25 10:47:06 +08:00
Feng c65d047fda QOS_I 2015-07-23 16:04:21 +08:00
Feng ffefcb6b17 Merge branch 'dev-hd' into dev 2015-07-20 08:34:05 +08:00
Feng 4278bd9db4 0.9.2 2015-07-19 09:47:29 +08:00
huangdan a43c9b3505 node api 2015-07-17 19:29:26 +08:00
Feng cd147c453f fix issue #196 2015-07-16 17:06:15 +08:00
Feng 5c46004c18 hooks 2015-07-16 15:55:58 +08:00
Feng eb097c1056 fix issue #193 2015-07-14 17:55:52 +08:00
Feng c63c74a18f blank 2015-07-14 17:46:29 +08:00
Feng b6121f6bcb plain 2015-07-13 08:46:57 +08:00
Feng da560798d1 0.9.1 2015-07-10 10:57:45 +08:00
Feng e59232c2ab fix issue #189 - Websocket(SSL) cannot work for emqttd_net:peername error 2015-07-10 10:48:09 +08:00
Feng 92b6bb4493 0.9.0 2015-07-09 10:17:26 +08:00
Feng 0b12082256 hibernate 2015-07-09 10:08:35 +08:00
Feng 711a875e23 misc 2015-07-08 22:12:33 +08:00
Feng 630dd4f089 https listener 2015-07-08 22:02:00 +08:00
Feng c85617c080 distributed session 2015-07-08 18:17:48 +08:00
Feng fcc0bb98e2 fix issue #184 2015-07-07 15:36:34 +08:00
Feng ed81eb5a9d 'client.acked' hook 2015-07-06 15:26:30 +08:00
Feng 4f20f9691a set_flag 2015-07-06 15:25:03 +08:00
Feng 949b70f277 subscribe, unsubscribe hooks 2015-07-06 14:07:24 +08:00
Feng 988e61708d fix session stats 2015-07-06 00:29:08 +08:00
Feng dcc378150d infinity 2015-07-05 23:57:27 +08:00
Feng d6ea474810 comment 2015-07-05 22:53:54 +08:00
Feng 4808cf31b5 vm 2015-07-05 21:00:12 +08:00
Feng a68fa754fe Merge branch 'dev-hd' into dev 2015-07-05 20:52:34 +08:00
Feng 1e86f7bc42 os:timestamp 2015-07-05 20:29:04 +08:00
Feng 895c9ddaed emqttd_message:make, hooks 2015-07-05 20:18:37 +08:00
Feng 4ff7f9b2fe global unique id 2015-07-05 20:15:53 +08:00
Feng 87dafdd7b2 client_id 2015-07-02 23:22:27 +08:00
huangdan 1dcf892a69 vm 2015-06-26 15:03:00 +08:00
Feng 288973aabb State = 2015-06-26 10:29:57 +08:00
Feng 8ea0707684 fix session 2015-06-24 22:48:35 +08:00
Feng Lee d09a0787ea fix sessions 2015-06-24 22:05:00 +08:00
Feng Lee 0f68186472 mqueue test 2015-06-24 09:26:22 +08:00
Feng Lee eeee584fef add 'clientid' 2015-06-24 03:07:59 +08:00
Feng Lee b4080a0adf ts 2015-06-24 02:51:56 +08:00
Feng Lee 82bd645d7a fix session issue 2015-06-24 01:56:44 +08:00
Feng Lee d0429f56e7 fix 'loads/0' export 2015-06-24 00:38:15 +08:00
Feng Lee 89c939b321 {subscribe, TopicTable} 2015-06-24 00:37:58 +08:00
Feng Lee 34fc0fb157 now_to_secs 2015-06-24 00:37:41 +08:00
Feng Lee 2ff78d7fc6 alarm 2015-06-24 00:37:02 +08:00
Feng Lee 7e97e39bd1 etc/plugins.config 2015-06-23 12:46:51 +08:00
Feng Lee 3e5675cc71 ipaddress 2015-06-23 12:20:41 +08:00
Feng Lee 8702ab838c 0.9 project structure 2015-06-22 16:18:33 +08:00
Feng Lee 3a6ed9a876 0.2 project structure 2014-12-06 19:12:29 +08:00
hejin 109e98d80c change heap size 2014-12-02 22:53:29 +08:00
hejin c12a0b236e add monitor 2014-12-01 22:54:48 +08:00
hejin acc491c799 uupdate go timeout 2014-12-01 17:15:02 +08:00
hejin 34bcd2b2db test 2014-08-19 16:05:21 +08:00
李方朔 13bf396306 fix issue#18 2013-11-05 00:21:30 +08:00
erylee 1f1099e667 add appmon 2013-10-31 17:36:40 +08:00
erylee 3e3dfe3fa2 fix client 2013-09-17 11:25:27 +08:00
erylee fd711f3fbc trie delete 2013-08-23 14:38:28 +08:00
erylee 570ca1aa78 fix issue#17 2013-07-16 14:39:38 +08:00
erylee 9bdbb84ed2 refactor header file 2013-06-28 11:01:23 +08:00
erylee 860532fc68 fix unsubscribe 'error topics' 2013-03-18 15:18:25 +08:00
erylee 3626979e31 0.1.5 bug fix 2013-01-05 16:21:37 +08:00
erylee 3979c83550 vsn 0.1.4 2013-01-04 16:36:03 +08:00
erylee ba5e21278e fix qos_2 subscribe 2013-01-04 16:29:35 +08:00
erylee 97d27e2456 fix qos_2 bugs 2013-01-04 13:24:18 +08:00
erylee 8b85ce4278 add publish/1 api 2013-01-03 21:03:00 +08:00
erylee 2c8bb114f9 fix qos_2 message flow 2013-01-03 20:30:07 +08:00
erylee 31c687f26c support trie topic structure 2013-01-01 20:16:02 +08:00
erylee 6d795c7273 add license 2012-12-27 21:55:41 +08:00
erylee dbad1cf920 fix cluster 2012-12-27 16:51:32 +08:00
erylee 58b1e258c1 add folder 2012-12-27 16:42:59 +08:00
Ery Lee 52cca0a908 vsn 0.1.2 2012-12-26 15:38:16 +08:00
Ery Lee 69b9e74a94 use ?INFO to print log 2012-12-26 15:25:27 +08:00
Ery Lee e7ba96b263 fix ctl api 2012-12-26 14:36:39 +08:00
erylee ea1e3c59a0 vsn 0.1.1 2012-12-24 17:16:37 +08:00
erylee 76169eb446 support topic cluster 2012-12-24 16:59:12 +08:00
erylee c082cbb27b fix topic record 2012-12-24 11:59:02 +08:00
erylee cd1e2c73d2 support client registry 2012-12-23 17:55:10 +08:00
erylee 8fa63244bb fix issue#3 'PUBLISH' RETAIN 2012-12-23 16:53:38 +08:00
erylee 7117d03a09 support keep alive 2012-12-23 16:14:02 +08:00
erylee a8e860b07d fix .app.src 2012-12-22 18:03:28 +08:00
erylee c1b9449c53 fix sub/pub 2012-12-22 17:35:28 +08:00
erylee 425bc2157e add auth support 2012-12-22 16:42:32 +08:00
erylee 87db1acf2b rm tmp 2012-12-22 14:28:29 +08:00
erylee 92ce6ef539 merge emqtt_processor to emqtt_client 2012-12-22 14:28:04 +08:00
erylee 0953344e06 fix status 2012-12-21 17:36:32 +08:00
erylee efc1d9f424 add bin/ and some files 2012-12-21 17:33:21 +08:00
erylee 6245fb4aa9 first workable 2012-12-21 13:24:48 +08:00
erylee fcb5ac6df3 add mqtt frame 2012-12-21 11:30:35 +08:00
erylee 0fabf9feb2 tcp options 2012-12-20 17:35:02 +08:00
erylee cc67e10e69 fix client 2012-12-20 16:44:57 +08:00
erylee a77bbf33e2 first workable 2012-12-20 16:30:51 +08:00
Ery Lee bac534c8c8 fix router 2012-12-19 13:45:04 +08:00
Ery Lee cb04c9c7e5 add file 2012-12-19 13:42:03 +08:00