Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Router ¶
type Router struct {
// contains filtered or unexported fields
}
Router manages all message routing
func NewRouter ¶
func NewRouter(cfg *config.Configuration, logger *logger.Logger, sentry *sentry.Service) (*Router, error)
NewRouter creates a new message router
func (*Router) AddNoPublishHandler ¶
func (r *Router) AddNoPublishHandler( handlerName string, topicName string, subscriber message.Subscriber, handlerFunc func(msg *message.Message) error, middlewares ...message.HandlerMiddleware, )
AddNoPublishHandler adds a handler that doesn't publish messages
Source Files
Click to show internal directories.
Click to hide internal directories.