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

4508 Commits

Author SHA1 Message Date
spring2maz 9e78c18681 Add get_forwards and get_subscriptions protal APIs 2019-02-28 11:17:27 +08:00
spring2maz 67376727c9 Add batch send support for emqx_client:publish/2 
also cover emqx_portal_mqtt with CT
 2019-02-28 11:17:27 +08:00
spring2maz b9e8bde3b0 Add first CT test for emqx_portal based on rpc 2019-02-28 11:17:27 +08:00
spring2maz 6d51d78dfc Add portal transport over emqx_client. 2019-02-28 11:17:27 +08:00
spring2maz 141af0d02c Add message handler callbacks option to emqx_client 
In this commit, msg_handler option is added to emqx_client.
so the caller can provide callbacks to handle puback, publish,
as well as disconnected events instead of always delivered
as message like Owner ! {publish, Msg} to the owner process.

This is to make it ready to implement emqx_portal_connect on
top of emqx_client.
 2019-02-28 11:17:27 +08:00
spring2maz fbe67e6784 Introduce new bridge impl 2019-02-28 11:17:27 +08:00
Gilbert c3e6f3c3b2 Improve try catch syntax (#2263) 
* Replace case catch.. with try ... catch
Prior to this change, case catch ... would cost a lot of performance
because it would retrieve the whole stacktrace. However, try...catch
will not retrieve the whole stacktrace. So try...catch syntax is better.
 2019-02-28 09:54:28 +08:00
tigercl a0fd9e63e0 Add data_dir to emqx.conf (#2271) 
* Add data_dir to emqx.conf
 2019-02-28 09:28:37 +08:00
linjun 1fe7431370 Adjusting test case 2019-02-27 16:33:49 +08:00
linjun 44529a278d Adjusting code 2019-02-27 14:39:49 +08:00
linjun e1a5188d09 Adjusting code 2019-02-27 14:00:11 +08:00
linjun 7af6051e25 Refactor code 2019-02-27 13:54:24 +08:00
linjun 760ac9f2f9 Add the value of attribute socktype in emqx_conn_type table 2019-02-27 11:09:45 +08:00
zhanghongtong b20e87f98e Merge remote-tracking branch 'origin/develop' 2019-02-25 09:33:02 +08:00
Feng Lee c8b243ed22 Change some '-type' attrs to '-opaque' and improve emqx_gc, emqx_inflight modules 
- Define 'GCS(St)' macro to improve emqx_gc module
- Define 'Inflight(MaxSize, Tree)' macro to improve emqx_inflight module
 2019-02-22 18:08:13 +08:00
linjun e16f2fe1fd Increasing coverage for emqx_message 2019-02-22 17:11:02 +08:00
Feng Lee 565c1a8c85 Optimize unset_flag/2 and add some specs 
- Optimize unset_flag/2
- Add some function specs
- Add emqx_message_SUITE to Makefile
 2019-02-22 17:06:52 +08:00
Feng Lee 82c337a040 Fix 'drpped' typo 
- Fix 'drpped' typo
- Add specs for exported functions
- Add 'group()' type in emqx_topic module
 2019-02-22 10:03:29 +08:00
Gilbert Wong ee9f278738 Merge branch 'develop' 2019-02-21 16:09:43 +08:00
Feng Lee 269b74232a Introduce some common types 2019-02-19 17:16:11 +08:00
Feng Lee 7a645dd9cc Add 'include/types.hrl' and introduce some common types 2019-02-19 17:16:11 +08:00
张奇怪 44d3eff094 Auto-pull-request-by-2019-02-19 (#2232) 
* Update Copyright to 2019 (#2191)

* Disable bridges by default (#2189)

* Fix warning logger args emqx#2195

* Ambiguity elimination (#2217)

* Fix emqx_ws_connection: prevent crashes on pong (#2210)

* Issue#2184 (#2194)

* Delete dep-vsn-check

* Format app.src
 2019-02-19 14:00:34 +08:00
Feng Lee 8751c10ea5 Update README 2019-02-11 15:44:45 +08:00
Feng Lee 11d9aaa002 Use the new site 'emqx.io' 2019-02-11 15:41:29 +08:00
turtleDeng 78ea56348c
Update Copyright to 2019 (#2191) 2019-01-29 10:46:51 +08:00
turtled 31e95b56c4 Update Copyright to 2019 2019-01-29 10:43:25 +08:00
Feng Lee 891ef2680e Merge branch 'emqx30' 2019-01-25 15:54:11 +08:00
turtleDeng 00863acea3
Merge emqx30 (#2181) 
* Change the reason code in will topic acl check (#2168)

* Fix bridge bug (#2160)

* Limit bridge QoS less than 1

* Improve shared sub dispatch implementation. (#2144)

* Upgrade ekka, esockd libraries

* Improve the 'try_open_session' function

* Reload config (#2180)
 2019-01-25 13:01:48 +08:00
Gilbert b461e26f25
Reload config (#2180) 
Reload config when restart or reboot emqx
 2019-01-24 23:55:57 +08:00
Feng Lee d5b17c516e Improve the 'try_open_session' function 2019-01-24 11:10:33 +08:00
Feng Lee bb9c41c9f0 Update rebar.config 2019-01-23 11:29:09 +08:00
Feng Lee 88dbbc3a44 Upgrade ekka, esockd libraries 2019-01-23 11:29:09 +08:00
spring2maz a6f138b55c Improve shared sub dispatch implementation. (#2144) 
Before this change, when shared dispatch ack is enabled (in config)
in case all subscribers are offline (all sessions gave negative ack)
the message is simply discarded.
In this change, it is ensured to have one session picked according to
configured dispatch strategy when no subscriber is online.
The messages dispatched in such scenario are then queued in session state.
 2019-01-22 09:57:37 +08:00
Gilbert 55ec358cd6 Fix bridge bug (#2160) 
* Fix bridge bug

* Fix ack bug

* Limit bridge QoS less than 1
 2019-01-22 09:42:32 +08:00
Gilbert 067d28dcb6 Change the reason code in will topic acl check (#2168) 
This chang the reason code to not authorized code.
 2019-01-21 09:49:29 +08:00
Shawn b8929a46c1 Fix the EXIT outputs in Travis CI (#2154) 
* Fix the Exit in testcases

* Fix Exit in emqx_mod_sup_SUITE

* Update testcases for log_tracer

* Fix Exit in emqx_protocol_SUITE

* Add will_acl_check

* Fix more Exits
 2019-01-17 17:14:51 +08:00
tigercl bc31faac6b Fix will msg (#2156) 
* Remove will_msg and will_topic from protocol state

* Modify try_open_session/1
 2019-01-17 13:57:42 +08:00
YoukiLin 3748cd434d Add test case for emqx_sys_mon (#2150) 2019-01-12 23:09:39 +08:00
Gilbert Wong 7aa46896df Fix typo 2019-01-11 16:41:20 +08:00
Gilbert Wong ec03f8e1fa Fix the deliver packet bug and add test case 2019-01-11 16:41:20 +08:00
turtleDeng a5f9466040 QoS0 msg support msgid (#2145) 
* QoS0 msg support msgid

* Fix testcase
 2019-01-11 11:47:10 +08:00
Feng Lee 5ccaaed34c Add 'next_events/1' and fix the 'process_incoming/3' function 2019-01-10 09:23:05 +08:00
Feng Lee 3e15ac0bbb Improve the design of 'emqx_client' module 
Use '{next_event, cast, Packet}' to replace 'gen_statem:cast/2'
 2019-01-10 09:23:05 +08:00
Feng Lee 30f32de13a Use map to replace 'state' record 2019-01-10 08:53:10 +08:00
Feng Lee e882af9369 Use the new logger macros 2019-01-10 08:53:10 +08:00
Feng Lee fe0f5333b3 Improve the pool design 
- Move 'emqx_pool:start_link/0' to emqx_pool_sup module
- Use the new log macros
- Add more test cases
 2019-01-10 08:49:58 +08:00
Gilbert 73ae8ad57f
Update erlang/otp version for ci (#2141) 2019-01-10 00:11:57 +08:00
terry-xiaoyu de65e21270 Disable lager 
This PR removes lager handlers and the `crash.log`, in case of some dependencies or plugins of emqx use lager.
 2019-01-09 12:21:20 +08:00
Feng Lee 36a4eaec02 Fix the test case for 'emqx_router:print_routes/1' 2019-01-09 12:10:54 +08:00
Feng Lee 52241a7804 Add more test cases for code coverage 2019-01-09 11:57:22 +08:00