Skip to content

Commit

Permalink
revert: switch back to any
Browse files Browse the repository at this point in the history
  • Loading branch information
franklinkim committed May 25, 2024
1 parent a4fa86a commit 9a32adc
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions integration/watermill/mpv2/messagehandler.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,9 +8,9 @@ import (
"github.com/pkg/errors"
)

func MessageHandler(handler func(payload *mpv2.Payload[map[string]any], msg *message.Message) error) func(msg *message.Message) ([]*message.Message, error) {
func MessageHandler(handler func(payload *mpv2.Payload[any], msg *message.Message) error) func(msg *message.Message) ([]*message.Message, error) {
return func(msg *message.Message) ([]*message.Message, error) {
var payload *mpv2.Payload[map[string]any]
var payload *mpv2.Payload[any]

// unmarshal payload
if err := json.Unmarshal(msg.Payload, &payload); err != nil {
Expand Down

0 comments on commit 9a32adc

Please sign in to comment.