15 lines
282 B
Go
15 lines
282 B
Go
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)
|
|
}
|