foomo/sesamy-go
1
0
Fork 0
mirror of https://github.com/foomo/sesamy-go.git synced 2025-10-16 12:35:43 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

refactor: move event handler

Browse Source
This commit is contained in:
Kevin Franklin Kim 2024-03-04 15:50:14 +01:00
parent caba7e1659
commit cdd4215ed8
No known key found for this signature in database
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
integration/watermill/messagehandler.go → integration/watermill/measurementprotocol/eventhandler.go
View File

@ -1,4 +1,4 @@
package watermill
package measurementprotocol
import (
"encoding/json"
@ -8,7 +8,7 @@ import (
"github.com/pkg/errors"
)
func MessageEventHandler(eventHandler func(event *mpv2.Event, msg *message.Message) error) func(msg *message.Message) ([]*message.Message, error) {
func EventHandler(eventHandler func(event *mpv2.Event, msg *message.Message) error) func(msg *message.Message) ([]*message.Message, error) {
return func(msg *message.Message) ([]*message.Message, error) {
var event *mpv2.Event
if err := json.Unmarshal(msg.Payload, &event); err != nil {