apps/mochi-mqtt
1
0
Fork 0
mirror of https://github.com/mochi-mqtt/server.git synced 2025-10-06 08:37:14 +08:00
Code Issues Packages Projects Releases Wiki Activity

track logged error

Browse Source
This commit is contained in:
mochi
2022-03-31 18:23:12 +01:00
parent b072a08f0b
commit ae6073c79c
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
server/server_test.go
View File

@@ -1521,6 +1521,9 @@ func TestServerProcessPublishHookOnProcessMessageModifyError(t *testing.T) {
s.Clients.Add(cl1) s.Clients.Add(cl1)
s.Topics.Subscribe("a/b/+", cl1.ID, 0) s.Topics.Subscribe("a/b/+", cl1.ID, 0)
var hook errorHook
s.Events.OnError = hook.onError
s.Events.OnProcessMessage = func(cl events.Client, pk events.Packet) (events.Packet, error) { s.Events.OnProcessMessage = func(cl events.Client, pk events.Packet) (events.Packet, error) {
pkx := pk pkx := pk
pkx.Payload = []byte("world") pkx.Payload = []byte("world")
@@ -1570,6 +1573,9 @@ func TestServerProcessPublishHookOnProcessMessageModifyError(t *testing.T) {
}, <-ack1) }, <-ack1)
require.Equal(t, int64(14), s.System.BytesSent) require.Equal(t, int64(14), s.System.BytesSent)
require.Equal(t, 1, hook.cnt)
require.Equal(t, fmt.Errorf("error"), hook.err)
} }
func TestServerProcessPuback(t *testing.T) { func TestServerProcessPuback(t *testing.T) {