7efd7b3ec0
Rename portal to bridge
2019-02-28 15:31:54 +08:00
771f8c052a
Merge branch 'develop' into introduce-new-bridge-impl
2019-02-28 15:14:40 +08:00
3e0fa87209
Remove the io:format
2019-02-28 15:09:13 +08:00
e3bc8e4f0a
Support batch delivery
...
- Upgrade the emqx_session module to support batch delivery
- Update emqx_protocol:deliver/2 to support batch delivery
- Update some test cases
2019-02-28 15:09:13 +08:00
08204fc7a8
Improve the emqx_connection module using gen_statem behaviour ( #2235 )
2019-02-28 15:08:29 +08:00
37c7e684b0
Adjusting code
2019-02-28 14:32:13 +08:00
16165ce935
Use conn_mod instead of socktype
2019-02-28 11:32:05 +08:00
f837ac47e7
Merge remote-tracking branch 'origin/develop'
2019-02-28 11:30:54 +08:00
d18f4ba550
Fix wrong config entries
2019-02-28 11:18:12 +08:00
911a813891
Fix copyright and unify log method
2019-02-28 11:18:12 +08:00
9dbc34c376
Ack replayq and allow retry in tests
2019-02-28 11:17:27 +08:00
75163e21f3
Reverse intensity/period in bridge SupFlag
2019-02-28 11:17:27 +08:00
afa0d98b8d
Disable bridge defaultly
2019-02-28 11:17:27 +08:00
ae92acf30f
Refactor portal supervisor
2019-02-28 11:17:27 +08:00
ec37225333
Add emqx_portal interfaces
2019-02-28 11:17:27 +08:00
921a45a505
Fix emqx_portal_mqtt_tests start function
2019-02-28 11:17:27 +08:00
d4495fd8e7
Add manual start API
2019-02-28 11:17:27 +08:00
796fc3b1ba
Fix app config generation ( #2245 )
2019-02-28 11:17:27 +08:00
1626cade28
Deleted batch publish support in emqx_portal_client
...
eqmx_portal_mqtt has to do single message publish calls for now
Also fix a bug in emqx_portal_mqtt ack collector
2019-02-28 11:17:27 +08:00
086a1d56b9
Drop unused config schema
...
bridge.$name.transport was added before we decided to derive
transport portocol based on the 'address' config.
i.e. when it's a remote erlang node, use gen_rpc
otherwise (must be IP or hostnmae), we should estabilish mqtt connection
2019-02-28 11:17:27 +08:00
efc9e34033
Make use of BUMP_PACKET_ID the only way to generate packet IDs
2019-02-28 11:17:27 +08:00
6e1d4ec261
Add emqx_portal SUITE to default CT list
2019-02-28 11:17:27 +08:00
d7e18c95c6
Fix spelling error
2019-02-28 11:17:27 +08:00
786a6eb696
Add APIs for subscription add / delete
2019-02-28 11:17:27 +08:00
599f5c8d4f
Add API emqx_portal:ensure_forward_absent
2019-02-28 11:17:27 +08:00
2903a810ce
Add emqx_portal:ensure_foreard_present API
2019-02-28 11:17:27 +08:00
9e78c18681
Add get_forwards and get_subscriptions protal APIs
2019-02-28 11:17:27 +08:00
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
b9e8bde3b0
Add first CT test for emqx_portal based on rpc
2019-02-28 11:17:27 +08:00
6d51d78dfc
Add portal transport over emqx_client.
2019-02-28 11:17:27 +08:00
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
fbe67e6784
Introduce new bridge impl
2019-02-28 11:17:27 +08:00
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
a0fd9e63e0
Add data_dir to emqx.conf ( #2271 )
...
* Add data_dir to emqx.conf
2019-02-28 09:28:37 +08:00
1fe7431370
Adjusting test case
2019-02-27 16:33:49 +08:00
44529a278d
Adjusting code
2019-02-27 14:39:49 +08:00
e1a5188d09
Adjusting code
2019-02-27 14:00:11 +08:00
7af6051e25
Refactor code
2019-02-27 13:54:24 +08:00
760ac9f2f9
Add the value of attribute socktype in emqx_conn_type table
2019-02-27 11:09:45 +08:00
b20e87f98e
Merge remote-tracking branch 'origin/develop'
2019-02-25 09:33:02 +08:00
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
e16f2fe1fd
Increasing coverage for emqx_message
2019-02-22 17:11:02 +08:00
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
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
ee9f278738
Merge branch 'develop'
2019-02-21 16:09:43 +08:00
269b74232a
Introduce some common types
2019-02-19 17:16:11 +08:00
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
8751c10ea5
Update README
2019-02-11 15:44:45 +08:00
11d9aaa002
Use the new site 'emqx.io'
2019-02-11 15:41:29 +08:00
Gilbert Wong