memory leak

[ChipArtem]

For generate a loading I create goroutines. Goroutines are created by a consumer and a producer. After these I send and read messages. Over time, my memory begins to leak.

func goConsumer(...) {
         ...
    ctx := context.TODO()
    conn, err := amqp.Dial(....)
    if err != nil {
    ....
    }
    defer conn.Close()
    session, err := conn.NewSession(ctx, nil)
    if err != nil {
         ...
    }
    defer session.Close(ctx)
    consumer, err := session.NewReceiver(ctx, q.Name, nil)
    if err != nil {
    ...
    }
    defer consumer.Close(ctx)
    for {
        select {
        case <-chTimer.C:
            return
        default:
            msg, err := consumer.Receive(ctx, nil)
            ....
            ctx = context.TODO()
            err = consumer.AcceptMessage(ctx, msg)
            ....
        }
    }
}

[jhendrixMSFT]

Can we please get more info on your scenario.

• are there multiple senders/receivers?
• are the senders/receivers short or long lived?
• what are typical message sizes and how big is the largest message (best guess is fine)?