message

README

Do not use this in production, this is just an experiment!

Documentation

Index

• type Handler
• type Message
• type MessageBus
  • func NewSimpleMessageBus(handlers []Handler) MessageBus

Types

type Handler

type Handler interface {
	ContextName() string
	MessageName() string
	Handle(msg Message) error
}

type Message

type Message interface {
	Name() string
	Context() string
}

type MessageBus

type MessageBus interface {
	Dispatch(msg Message) error
}

func NewSimpleMessageBus

func NewSimpleMessageBus(handlers []Handler) MessageBus