Commit Graph
76 Commits
Author SHA1 Message Date
ZhangJian He a85e9904c2 Add addr in broekr log (#146) 2022-04-04 20:41:33 +08:00
ZhangJian He a501565bab Allow publish message by clientId (#147) 2022-04-04 20:41:04 +08:00
chowyu12andzhouyy bf2b91c535 update: go.mod and go version (#142)
Co-authored-by: zhouyy <zhouyy@ickey.cn>
2022-01-19 11:16:24 +08:00
ZhangJian He 108e934a85 [cleanup] delete comment out code (#137) 2022-01-10 10:59:39 +08:00
ZhangJian He 46b64e5b84 Close conn when read connect packet error (#136) 2022-01-10 10:59:15 +08:00
ZhangJian He ab117be4a8 Allow Broker DisConnect connections by ClientId (#135)
* Allow Broker DisConnect connections by ClientId

* Allow Broker DisConnect connections by ClientId
2022-01-05 11:15:45 +08:00
ZhangJian He 878e7fce3f Rmoeve unnecessary type convert (#134) 2022-01-05 11:15:26 +08:00
muXxerandLuca Moser 1d6979189a use locks around client maps (#126)
Co-authored-by: Luca Moser <moser.luca@gmail.com>
2021-08-10 10:46:38 +08:00
TrickIt 068d5e893c fix: close the connection after send connection refused connack packet. (#121) 2021-06-30 14:13:43 +08:00
Michael Stapelberg 524a9af060 retry listening indefinitely (#105)
When starting hmq immediately after booting, the IP address specified in the
--host flag (e.g. --host=10.0.0.217) might not be configured yet.

Without this commit, hmq would try to listen, give up, and then just hang.
With this commit, hmq automatically recovers.
2021-01-11 10:21:02 +08:00
chujiangke 481a61c520 fix (#90) 2020-06-24 15:14:25 +08:00
gerdstolpmann 839041e912 do not expect "Origin" header for websocket connections (#80)
* websocket: do not check the presence of the "Origin" header

* avoid using http.DefaultServeMux
2020-04-04 10:40:12 +08:00
gerdstolpmann 17dac26996 if used as library, allow that the auth and bridge plugins can be set by (#79)
struct, and not only by name
2020-04-03 14:49:50 +08:00
joy.zhou 57fce9c7dc Update broker.go 2019-12-25 17:12:07 +08:00
joy.zhou 44fa819f62 update some logic 2019-11-14 11:09:15 +08:00
joy.zhou a3fc611615 fix issue 2019-09-30 11:04:46 +08:00
joy.zhou 69a26f8cd9 update plugin 2019-08-19 10:33:19 +08:00
joy.zhou 4c5a48a44b Plugins update log (#47)
* modify

* update

* add acl

* add feature

* update dockerfile

* add deploy

* update

* update

* plugins

* plugins

* update

* update

* update

* fixed

* remove

* fixed

* add log

* update

* fixed

* update

* fix config

* add http api

* add http api

* resp

* add config for work chan

* update

* fixed

* update

* disable trace

* fixed

* change acl

* fixed

* fixed res

* dd

* dd

* ddd

* dd

* update

* fixed

* update

* add

* fixed

* update key

* add log

* update

* format

* update

* update auth

* update

* update readme

* added

* update

* fixed

* fixed

* fix

* upade

* update

* update

* update
2019-07-25 16:01:40 +08:00
joy.zhou c6b1f1db42 Plugins support (#46)
* modify

* update

* add acl

* add feature

* update dockerfile

* add deploy

* update

* update

* plugins

* plugins

* update

* update

* update

* fixed

* remove

* fixed

* add log

* update

* fixed

* update

* fix config

* add http api

* add http api

* resp

* add config for work chan

* update

* fixed

* update

* disable trace

* fixed

* change acl

* fixed

* fixed res

* dd

* dd

* ddd

* dd

* update

* fixed

* update

* add

* fixed

* update key

* add log

* update

* format

* update

* update auth

* update

* update readme

* added

* update

* fixed

* fixed

* fix

* upade

* update

* update
2019-07-25 13:54:42 +08:00
joy.zhou c350d16ca1 add fix pool for message order (#42)
* fix pool for message order

* add go modules
2019-04-24 14:54:21 +08:00
joyz 6193be74fa Merge branch 'master' of https://github.com/fhmq/hmq 2019-01-22 22:11:59 +08:00
joyz 90beada459 some modify 2019-01-22 22:11:54 +08:00
Marc Magnin 6c7fe6a0f7 simple fix (#35) 2019-01-07 19:56:00 +08:00
joy.zhou 7547ad3bdc Restruct (#34)
* modify

* remove

* modify

* modify

* remove no use

* add online/offline notification

* modify

* format log

* add reference
2018-12-26 14:51:13 +08:00
joy.zhou 5ed4728575 Wpool (#23)
* pool

* pool

* wpool
2018-04-04 13:49:52 +08:00
zhouyuyan c0fea6a5ba modify_message_pool 2018-02-24 13:19:43 +08:00
joy.zhou 7155667f6c Pool (#16)
* add pool

* elastic workerpool

* del buf

* modify usage

* modify readme
2018-02-03 12:42:25 +08:00
Marc Magnin ef252550dc fhmq/hmq#5 added zap logger (#11) 2018-01-26 13:51:36 +08:00
zhouyuyan 93b21777ff add lisence 2018-01-25 13:47:50 +08:00
Marc Magnin ca3951769a fhmq/hmq#2 added full package ref 2018-01-23 15:29:16 +01:00
zhouyuyan 0439e7ce90 fxi ws conn 2018-01-22 09:30:08 +08:00
zhouyuyan dc0f2185ab skip self 2018-01-19 13:53:47 +08:00
zhouyuyan 114e6f901e modify cluster 2018-01-19 13:41:17 +08:00
zhouyuyan 819b4725f2 modify route 2018-01-18 09:17:48 +08:00
zhouyuyan 7db7edaa17 cluster fix 2018-01-17 09:39:07 +08:00
zhouyuyan 1d6f6a4a71 add cluster 2018-01-16 16:50:10 +08:00
zhouyuyan 123bb7210f move dispatcher 2018-01-02 10:55:28 +08:00
zhouyuyan 5786e69b01 modify cluster logic 2017-11-21 14:05:06 +08:00
zhouyuyan 6a89b627d4 add clientID in log for debug 2017-11-02 15:31:57 +08:00
zhouyuyan a7fb7f1912 modify close old connect connection logic 2017-10-26 15:57:19 +08:00
zhouyuyan 4646042b7f disconnect 2017-09-12 15:37:05 +08:00
zhouyuyan 6b50060eae free memory 2017-09-12 09:17:36 +08:00
zhouyuyan 96277996f0 packet 2017-09-12 09:15:08 +08:00
zhouyuyan 5601632a33 packet 2017-09-11 17:00:02 +08:00
zhouyuyan cc1b3239ad remote logix fixed 2017-09-11 11:10:06 +08:00
zhouyuyan 476d22568b del statemonitor 2017-09-11 09:29:52 +08:00
chowyu08 c85ba76f8f 'status' 2017-09-09 16:04:40 +08:00
chowyu08 f3b2924b07 'addwss' 2017-09-09 15:37:00 +08:00
zhouyuyan 7d6fcb7d65 fix ws buf 2017-09-08 16:04:39 +08:00
zhouyuyan 258912b33a lb 2017-09-08 10:44:01 +08:00