fix: Use individual ACK policy for artemismq image (#180)

kedacore · Oct 30, 2024 · aae367b · aae367b
1 parent 8b50302
commit aae367b
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/e2e/images/artemis/cmd/main.go b/e2e/images/artemis/cmd/main.go
@@ -73,7 +73,7 @@ func consumeMessages() {
 		panic(err)
 	}
 	defer conn.Disconnect()
-	sub, err := conn.Subscribe(destination, stomp.AckAuto, stomp.SubscribeOpt.Header("subscription-type", "ANYCAST"))
+	sub, err := conn.Subscribe(destination, stomp.AckClientIndividual, stomp.SubscribeOpt.Header("subscription-type", "ANYCAST"))
 	if err != nil {
 		panic(fmt.Errorf("could not subscribe to queue %s: %v", destination, err))
 	}
@@ -87,6 +87,7 @@ func consumeMessages() {
 			panic(fmt.Errorf("failed to decode message: %v: %v", msg.Header, err))
 		}
 		log.Println(*m)
+		conn.Ack(msg)
 		time.Sleep(time.Duration(sleep * int(time.Millisecond)))
 	}
 }