pkg/amqp/defaultmiddlewares/routeDeclaration.go
RouteDeclarationMiddleware
has 21 methods (exceeds 20 allowed). Consider refactoring. Open
Open
type RouteDeclarationMiddleware struct {
// declareQueues is a map queues that must be declared upon re-establishing the
// channel. We use a map so we can remove queues from this list on queue delete.
declareQueues *sync.Map
// declareExchanges us a map of exchanges that must be declared upon re-establishing
Method RouteDeclarationMiddleware.reconnectHandler
has 6 return statements (exceeds 4 allowed). Open
Open
func (middleware *RouteDeclarationMiddleware) reconnectHandler(
ctx context.Context,
args amqpmiddleware.ArgsChannelReconnect,
next amqpmiddleware.HandlerChannelReconnect,
) (amqpmiddleware.ResultsChannelReconnect, error) {