router

Documentation

Index

• func NewDefaultRouter(opts Options) (*message.Router, error)
• func RestoreContext(h message.HandlerFunc) message.HandlerFunc
• type Options
  • func (o *Options) Validate() error

Functions

func NewDefaultRouter

func NewDefaultRouter(opts Options) (*message.Router, error)

NewDefaultRouter creates a new router with the default middlewares, in case your consumer would mandate a different setup, feel free to create your own router

func RestoreContext

func RestoreContext(h message.HandlerFunc) message.HandlerFunc

RestoreContext ensures that the original context is restored after the handler is done processing the message.

This helps with https://github.com/ThreeDotsLabs/watermill/issues/467

Types

type Options

type Options struct {
	Subscriber message.Subscriber
	Publisher  message.Publisher
	Logger     *slog.Logger

	Config config.ConsumerConfiguration
}

func (*Options) Validate

func (o *Options) Validate() error