stffabi
f5fc5e8c44
Subscribe: Only send retained messages if ACLs has allowed subscription to the topic
2022-03-17 09:25:29 +01:00
stffabi
1f86168d9d
Publish: Set the retain flag in the fixedheader ( #42 )
...
* Publish: Set the retain flag in the fixedheader
2022-03-16 18:12:07 +00:00
mochi
ab25083ed2
Merge branch 'master' of https://github.com/mochi-co/mqtt into v1.1.2
...
# Conflicts:
# server/internal/clients/clients.go
2022-03-16 18:09:00 +00:00
JB
3286d5a484
Replace Travis with Github Actions ( #41 )
...
* Remove Travis CI
* Add Github Actions Workflow
* Update badges for build status, coverage, report card, doc reference
* use actions for all pull requests and pushes
* test all files for coverage
* Apply gofmt -s to simplify code
* Fix typos
* Cleanup comments
* Cleanup comments
Co-authored-by: mochi <mochimou@icloud.com >
2022-03-15 19:56:42 +00:00
mochi
d6a92cc5bd
Add Keyed fields to events.Client for readability and go vet
2022-03-15 18:44:49 +00:00
mochi
325d44d478
Add missing method comments
2022-03-15 18:44:21 +00:00
Joshua MacDonald
0a5f6d3a9d
Add an OnError handler; report the reason for disconnects. ( #38 )
2022-03-15 17:59:52 +00:00
JB
6e16765f60
revert server version
2022-02-24 21:19:22 +00:00
JB
c8c0a5a094
Revert "added redis persistence mode"
2022-02-24 21:10:39 +00:00
JB
4a833dd081
Update server version
2022-02-24 21:07:54 +00:00
narwal
b6529f05d3
add redis persistence mode and example
2022-02-22 18:57:31 +08:00
mochi
7f76445cc8
update server version
2022-01-30 10:39:49 +00:00
mochi
eda03d4338
optimise Server struct
2022-01-30 10:30:34 +00:00
mochi
a60c96c889
Update comment for clarity
2022-01-28 21:04:15 +00:00
mochi
86e0a5827e
Update version to 1.1.0
2022-01-26 20:49:53 +00:00
Rob Kennedy
471ca00a64
Make atomics work on 32-bit systems
...
On 32-bit systems, `atomic` requires its 64-bit arguments to have 64-bit
alignment, but the compiler doesn't help ensure that's the case. In this
commit, fields that don't need to hold large numbers have been converted
to 32-bit types, which are always aligned correctly on all platforms.
For fields that may hold large numeric values, padding has been added to
get the necessary alignment, and tests have been added to avoid
regressions.
2022-01-25 00:22:26 -06:00
mochi
a2c0749640
Update server version to 1.0.5
2022-01-24 18:46:34 +00:00
mochi
d15ad682bf
Call OnDisconnect Event if applicable
2022-01-24 17:42:19 +00:00
mochi
a360ea6a6c
Call OnConnect Event if applicable
2022-01-24 17:37:11 +00:00
mochi
811ae0e1be
Prevent locks being copied by passing non-pointer to FromClient
2022-01-24 17:36:14 +00:00
mochi
0758bc961c
Add AllowClients check in publishToSubscribers
...
If AllowClients has been set on a packet, ensure only clients in the slice are sent the message
2022-01-14 17:02:31 +00:00
mochi
9d0ea957bb
Increment server version
2022-01-14 16:58:48 +00:00
mochi
fb136483d0
Revert server version
2022-01-10 23:50:40 +00:00
mochi
b209cd95f1
increment server version
2022-01-10 23:48:33 +00:00
mochi
a674632cce
Increment server version
2022-01-10 23:41:46 +00:00
mochi
b277600823
Increment server version to 1.0.1
2022-01-05 21:14:11 +00:00
mochi
8890bb9dd4
remove redundant code
2022-01-05 21:05:20 +00:00
mochi
c2a42a16ca
Merge OnMessage and OnMessageModify
2022-01-05 20:59:14 +00:00
mochi
d4cbf1abdc
Add Event Hooks
...
Adds basic event hooks (OnMessage, OnMessageModify) to the server using the new events library.
2022-01-05 20:38:00 +00:00
mochi
b5685ca0ee
update packets library import reference
2022-01-05 17:01:15 +00:00
mochi
484e4abd56
Directly publish messages from embedding system
...
When the broker is embedded in a larger Go codebase, it is beneficial to be able to publish messages directly from the system to topics. This change provides a Publish method which adds messages to an inline publishing queue in a separate goroutine, which are then processed in the standard way and issued to all clients with matching topic filters.
2022-01-05 13:32:12 +00:00
Mochi
e96ef0170d
Code and Comments cleanup, vendor deps
2020-02-08 13:24:31 +00:00
Mochi
d1daa843df
Persistence V1
2020-02-04 21:18:29 +00:00
Mochi
85f269af5d
Adds delete from persistence
2020-02-02 14:38:39 +00:00
Mochi
4a10b0b676
Adds more persistence tests
2020-02-01 18:35:46 +00:00
Mochi
216b04011f
Load persistence into server
2020-01-25 13:21:24 +00:00
Mochi
79d1ee392b
Progress on persistence
2020-01-15 21:32:40 +00:00
Mochi
6a2d5bede1
Websocket Listener
2020-01-04 20:06:37 +00:00
Mochi
4d3b1d7da4
Publish $SYS Stats to topics
2019-12-31 23:49:17 +00:00
Mochi
19f74cb691
Basic $SYS stats
2019-12-31 19:02:55 +00:00
Mochi
be4240b371
Http Sys Stats listener
2019-12-31 16:33:50 +00:00
Mochi
b6184987e8
Restructures code
2019-12-31 15:02:16 +00:00
