Read stops after 18 messages on queue

[bugrakocabay]

Hello,

I have an ActiveMQ server running on docker. I am sending messages to queue in a for loop to experiment but after 18 messages the client stops reading the messages. What could be the reason for this?

Docker: docker run -e ARTEMIS_USER=myUser -e ARTEMIS_PASSWORD=myPass --name mycontainer -it -p 61616:61616 -p 8161:8161 apache/activemq-artemis:latest-alpine

Message producer:

func connectActiveMQ() (*stomp.Conn, error) {
    var err error
    netConn, err := net.DialTimeout("tcp", "localhost:61616", 10*time.Second)
    if err != nil {
        return nil, err
    }

    stompConn, err := stomp.Connect(netConn, stomp.ConnOpt.Login("myUser", "myPass"))
    if err != nil {
        return nil, err
    }

    _, err = stompConn.Subscribe("test", stomp.AckAuto)
    if err != nil {
        log.Printf("Failed to subscribe to ActiveMQ: %s", err)
        return nil, err
    }

    return stompConn, nil

func main() {
        conn, err := connectActiveMQ()
    if err != nil {
        log.Fatalf("Failed to connect to ActiveMQ: %s", err)
    }
    for j := 0; j < 100; j++ {
        go func() {
            err = conn.Send("test", "text/plain", []byte(strconv.Itoa(j+1)), stomp.SendOpt.NoContentLength, stomp.SendOpt.Header("persistent", "true"))
            if err != nil {
                log.Printf("Failed to send message: %s", err)
            }
        }()
        log.Printf("Sent message: %s", j)
    }
}

Message consumer:

func connectActiveMQ() (*stomp.Subscription, error) {
    var err error
    netConn, err := net.DialTimeout("tcp", "localhost:61616", 10*time.Second)
    if err != nil {
        return nil, err
    }

    stompConn, err := stomp.Connect(netConn, stomp.ConnOpt.Login("myUser", "myPass"))
    if err != nil {
        return nil, err
    }

    c, err := stompConn.Subscribe("test", stomp.AckAuto)
    if err != nil {
        return nil, err
    }

    return c, nil
}

func main() {
    c, err := connectActiveMQ()
    if err != nil {
        log.Fatalf("Failed to connect to ActiveMQ: %s", err)
    }

    go func() {
        for {
            m, err := c.Read()
            if err != nil {
                log.Printf("Failed to read message from ActiveMQ: %s", err)
            }
            log.Printf("Received message: %s", m.Body)
        }
    }()

    signalChannel := setupSignalHandling()
    waitForShutdown(signalChannel)
}

[worg]

I'll try to make time this weekend to look into this