15f8d3208f
Fix message dropped
...
Prior to this change, when store_qos0 option is set to false, the hook
`message.dropped` would not be triggered. It is wrong design and when
the ignore_loop is enabled or nl is set to 1, the hook
`message.dropped` also would not be triggered.
2019-04-03 20:33:58 +08:00
fc2df9aff5
Adapt to new export style
2019-03-22 14:58:24 +08:00
fbe67e6784
Introduce new bridge impl
2019-02-28 11:17:27 +08:00
7a645dd9cc
Add 'include/types.hrl' and introduce some common types
2019-02-19 17:16:11 +08:00
31e95b56c4
Update Copyright to 2019
2019-01-29 10:43:25 +08:00
4f84a31d02
Update copyright ( #2093 )
2018-12-21 11:06:50 +08:00
32d3826440
Replace macro QOS$i to QOS_$I
...
The two styles of qos macro name in one project is chaotic. It is not
a good practice.
So I change the QOS$i to QOS_$i
2018-11-08 20:42:31 +08:00
ae743ad1f0
Rewrite emqx_mqueue.erl
...
Fixed bugs:
- Priority queue lack of a `len + 1` logic in `in/2`
Changed behaviors:
- Topics not found in priority table (from config) will be treated with default priority,
instead of hasing topic name to a priority number.
- Default priority is now configurable (it was always lower than all configured priorities)
- The dropped message due to reaching `max_len` is now returned from `in/2`,
so the queue owner (`in/2` caller) can perform autopsy on it
2018-10-27 14:21:53 +02:00
8db9f3e81d
Update & clarify module doc for emqx_mqueue.erl
2018-09-13 09:08:07 +08:00
1f2bbe3eb8
Support priority queue
2018-08-30 18:29:20 +08:00
8492513094
Merge branch 'emqx30' into emqx30-feng
2018-08-29 23:11:24 +08:00
567aeb274f
Define types in emqx_types, emqx_mqtt_types modules
2018-08-29 23:08:55 +08:00
f4330b8af3
Add some test suites and fix bugs
2018-08-29 19:19:22 +08:00
f80cd2d986
Improve the MQTT over Websocket connection
2018-08-11 17:57:19 +08:00
7d0cba9427
Add MQTT 5.0 supports for connection, protocol and session modules
2018-08-06 16:33:10 +08:00
eeeed35e2a
Remove the alarm_fun arg from emqx_mqueue:new/3
2018-07-19 10:46:05 +08:00
7ee54aac28
Add 'qos' field to message record
2018-07-18 23:41:00 +08:00
62aa072f2f
Upgrade for MQTT Version 5.0 and Erlang/OTP R21
2018-07-18 13:43:17 +08:00
71acf91ace
Replace lager with emqx_log
2018-04-09 12:34:53 +08:00
9976327c8d
Add emqx_mqtt module
2018-03-23 18:13:09 +08:00
282e341433
EMQ X R3.0 - Improve the design of pubsub and router
2018-03-21 16:48:52 +08:00
6a957e1b33
Support MQTT Version 5.0
2018-03-02 20:18:27 +08:00
f7f0f27e4d
Parse and serialize MQTT 5.0 protocol packets
2018-02-27 23:45:55 +08:00
b63c34ab14
Merge the latest master branch
2018-02-24 11:27:09 +08:00
4b8cd18f5d
Merge with EMQ X project
2017-10-09 19:43:06 +08:00
Gilbert Wong