ChannelMiddlewares has 46 methods (exceeds 20 allowed). Consider refactoring.

Open

type ChannelMiddlewares struct {
    // TRANSPORT METHOD HANDLERS
    // -------------------------

    // transportClose is the handler invoked when transportManager.Close is called.

Method ChannelMiddlewares.innerAddProviderMethods has 165 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (config *ChannelMiddlewares) innerAddProviderMethods(
    provider amqpmiddleware.ProvidesMiddleware,
) (methodsFound bool) {
    if hasMethods, ok := provider.(amqpmiddleware.ProvidesClose); ok {
        config.AddClose(hasMethods.Close)

Channel has 36 methods (exceeds 20 allowed). Consider refactoring.

Open

type Channel struct {
    // underlyingChannel is the the transport object that contains our current underlying
    // connection.
    // The current, underlying channel object.
    underlyingChannel *BasicChannel

LoggingMiddlewareChannel has 34 methods (exceeds 20 allowed). Consider refactoring.

Open

type LoggingMiddlewareChannel struct {
    loggingMiddlewareCore
}

File logging.go has 595 lines of code (exceeds 500 allowed). Consider refactoring.

Open

package defaultmiddlewares

import (
    "context"
    "github.com/peake100/rogerRabbit-go/pkg/amqp/amqpmiddleware"

Method ChannelMiddlewares.innerAddProviderMethods has a Cognitive Complexity of 41 (exceeds 20 allowed). Consider refactoring.

Open

func (config *ChannelMiddlewares) innerAddProviderMethods(
    provider amqpmiddleware.ProvidesMiddleware,
) (methodsFound bool) {
    if hasMethods, ok := provider.(amqpmiddleware.ProvidesClose); ok {
        config.AddClose(hasMethods.Close)

• Read up
  Read up

channelHandlerBuilder has 30 methods (exceeds 20 allowed). Consider refactoring.

Open

type channelHandlerBuilder struct {
    connection *Connection
    channel    *Channel

    middlewares ChannelMiddlewares

RouteDeclarationMiddleware has 21 methods (exceeds 20 allowed). Consider refactoring.

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

Function newConnection has 56 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func newConnection(url string, config Config) (*Connection, error) {
    // Extract our config into a streadway.Config
    streadwayConfig := streadway.Config{
        SASL:            config.SASL,
        Vhost:           config.Vhost,

Method Producer.Publish has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

    ctx context.Context,
    exchange string,
    key string,
    mandatory bool,
    immediate bool,

Method AmqpSuite.publishMessagesConfirm has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

    ctx context.Context,
    t *testing.T,
    count int,
    confirmations <-chan amqp.Confirmation,
    returns <-chan amqp.Return,

Method Producer.QueueForPublication has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

    ctx context.Context,
    exchange string,
    key string,
    mandatory bool,
    immediate bool,

Method Producer.queueOrder has 6 return statements (exceeds 4 allowed).

Open

func (producer *Producer) queueOrder(order *Publication) error {
    // We are going to use a closure to grab and release the lock so we don't hold onto
    // it longer than we have to.
    err := func() error {
        // Put a read hold on closing the order channel so it isn't closed out from

Method RouteDeclarationMiddleware.reconnectHandler has 6 return statements (exceeds 4 allowed).

Open

func (middleware *RouteDeclarationMiddleware) reconnectHandler(
    ctx context.Context,
    args amqpmiddleware.ArgsChannelReconnect,
    next amqpmiddleware.HandlerChannelReconnect,
) (amqpmiddleware.ResultsChannelReconnect, error) {

Method loggingMiddlewareCore.logMethod has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

    ctx context.Context,
    methodLogger zerolog.Logger,
    args interface{},
    results interface{},
    err error,

Method Channel.Publish has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

    exchange string,
    key string,
    mandatory bool,
    immediate bool,
    msg Publishing,

Method DefaultLogging.logDeliveryResult has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

    delivery amqp.Delivery,
    requeue bool,
    err error,
    start time.Time,
    logger zerolog.Logger,

Method AmqpSuite.createSingleTestQueue has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

    name string,
    exchange string,
    exchangeKey string,
    cleanup bool,
    channel *amqp.Channel,