Documentation ¶
Index ¶
- Constants
- func AckNack() consumer.Middleware
- func ExpireToTimeout(defaultTimeout time.Duration) func(next consumer.Handler) consumer.Handler
- func GetLogger(ctx context.Context) (logger.Logger, bool)
- func HasCorrelationID() consumer.Middleware
- func HasReplyTo() consumer.Middleware
- func Logger(l logger.Logger) func(next consumer.Handler) consumer.Handler
- func Recover() consumer.Middleware
- func WithLogger(ctx context.Context, l logger.Logger) context.Context
Constants ¶
View Source
const Ack = "ack"
View Source
const Nack = "nack_requeue"
View Source
const Requeue = "requeue"
Variables ¶
This section is empty.
Functions ¶
func AckNack ¶
func AckNack() consumer.Middleware
func ExpireToTimeout ¶
func HasCorrelationID ¶
func HasCorrelationID() consumer.Middleware
func HasReplyTo ¶
func HasReplyTo() consumer.Middleware
func Recover ¶
func Recover() consumer.Middleware
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.