Files
atomctl/templates/project/pkg/atom/contracts/events.go.tpl
2025-01-23 19:03:17 +08:00

15 lines
282 B
Smarty

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