Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Intercepter ¶ added in v0.19.4
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.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.