messaging

type Message ¶

type Message = base.Message

type MessageHandler ¶

type MessageHandler = base.MessageHandler

type MessageHandlerRegisterer ¶

type MessageHandlerRegisterer = base.MessageHandlerRegisterer

type Router ¶

type Router struct {
	// contains filtered or unexported fields
}

Router maps subjects to MessageHandlers.

func NewRouter(l logger.Logger) *Router

func (r *Router) Handle(ctx context.Context, subject string, m Message) error

func (r *Router) Register(subject string, h MessageHandler)

func (r *Router) Subjects() []string