Versions in this module Expand all Collapse all v1 v1.0.1 Aug 11, 2025 Changes in this version + type Consumer interface + Close func() error + Consume func() (Message, error) + type ConsumerCloseError struct + func (ConsumerCloseError) Error() string + type EmptyRoutError struct + func (EmptyRoutError) Error() string + type Instance struct + func (l *Instance) ListenAndServe() error + func (l *Instance) Shutdown(ctx context.Context) error + type Listener struct + func NewListener(consumer Consumer) *Listener + func (l *Listener) Init(router Router) *Instance + func (l *Listener) SetConcurrency(n int) error + func (l *Listener) SetLogger(logger LoggerFunc) + type LoggerFunc func(error) + type Message interface + Ack func() error + Body func() []byte + ContentType func() string + Headers func() map[string]interface{} + IsRedelivered func() bool + Nack func() error + Reject func() error + RoutingKey func() string + type Publisher interface + Close func() error + Publish func(context.Context, []byte) error + type Router map[string]func(message Message) + func NewRouter() Router + func (r Router) Add(key string, f func(message Message)) + type UnroutedMessage struct + func (UnroutedMessage) Error() string v1.0.0 Jul 15, 2025
Go to main page