middlewares

Documentation

Index

• func Intercepter(ch chan extensions.BrokerMessage) extensions.Middleware
• func Logging(logger extensions.Logger) extensions.Middleware
• func Recovery(logger extensions.Logger) extensions.Middleware

Functions

func Intercepter

func Intercepter(ch chan extensions.BrokerMessage) extensions.Middleware

Intercepter is a middleware that intercepts messages in reception and in publication.

func Logging

func Logging(logger extensions.Logger) extensions.Middleware

Logging is a middleware that logs messages in reception and in publication.

func Recovery

func Recovery(logger extensions.Logger) extensions.Middleware

Recovery is a middleware that recovers from panic in middlewares coming after it and user code from subscription.