Files
atom/contracts/events.go
2024-12-31 15:38:20 +08:00

10 lines
204 B
Go

package contracts
import "github.com/ThreeDotsLabs/watermill/message"
type EventHandler interface {
Topic() string
PublishToTopic() string
Handler(msg *message.Message) ([]*message.Message, error)
}