middleware

Documentation

Index

• func AckDelivery(logFunc amqprpc.LogFunc) amqprpc.ServerMiddlewareFunc
• func PanicRecovery(...) amqprpc.ServerMiddlewareFunc
• func PanicRecoveryLogging(logFunc amqprpc.LogFunc) amqprpc.ServerMiddlewareFunc

Functions

func AckDelivery

func AckDelivery(logFunc amqprpc.LogFunc) amqprpc.ServerMiddlewareFunc

AckDelivery is a middleware that will acknowledge the delivery after the handler has been executed. Any error returned from d.Ack will be passed to the provided logFunc.

func PanicRecovery

func PanicRecovery(onRecovery func(interface{}, context.Context, *amqprpc.ResponseWriter, amqp.Delivery)) amqprpc.ServerMiddlewareFunc

PanicRecovery is a middleware that will recover any panics caused by a handler down the middleware chain. If a panic happens the onRecovery func will be called with the return value from recover().

func PanicRecoveryLogging

func PanicRecoveryLogging(logFunc amqprpc.LogFunc) amqprpc.ServerMiddlewareFunc

PanicRecoveryLogging is a middleware that will recover any panics caused by a handler down the middleware chain. If a panic happens the value will be logged to the provided logFunc.