This is an automated email from the ASF dual-hosted git repository. squakez pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-k.git
commit 876257bfb99ab9e3e45785c5e56d43e2222793bf Author: Dhvani Dave <[email protected]> AuthorDate: Sun Oct 18 04:38:39 2026 -0400 use broker pod address for artemis management endpoint --- e2e/arkmq/arkmq_keda_test.go | 2 +- e2e/arkmq/files/keda-arkmq-to-log-auto.yaml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/e2e/arkmq/arkmq_keda_test.go b/e2e/arkmq/arkmq_keda_test.go index 210a39ba6..ec9a80d76 100644 --- a/e2e/arkmq/arkmq_keda_test.go +++ b/e2e/arkmq/arkmq_keda_test.go @@ -46,7 +46,7 @@ func TestArkMQKedaAutoDiscovery(t *testing.T) { g.Expect(scaledObj.Spec.Triggers[0].Metadata["queueName"]).To(Equal("my-queue")) g.Expect(scaledObj.Spec.Triggers[0].Metadata["brokerAddress"]).To(Equal("my-queue")) // Merged from autoMetadata - g.Expect(scaledObj.Spec.Triggers[0].Metadata["managementEndpoint"]).To(Equal("my-broker-hdls-svc.arkmq.svc:8161")) + g.Expect(scaledObj.Spec.Triggers[0].Metadata["managementEndpoint"]).To(Equal("my-broker-ss-0.my-broker-hdls-svc.arkmq.svc:8161")) g.Expect(scaledObj.Spec.Triggers[0].Metadata["brokerName"]).To(Equal("amq-broker")) ExpectExecSucceed(t, g, Kubectl("delete", "pipe", integrationName, "-n", ns)) diff --git a/e2e/arkmq/files/keda-arkmq-to-log-auto.yaml b/e2e/arkmq/files/keda-arkmq-to-log-auto.yaml index d63858e67..f2c262042 100644 --- a/e2e/arkmq/files/keda-arkmq-to-log-auto.yaml +++ b/e2e/arkmq/files/keda-arkmq-to-log-auto.yaml @@ -39,5 +39,5 @@ spec: maxReplicaCount: 1 autoMetadata: artemis-queue: - managementEndpoint: my-broker-hdls-svc.arkmq.svc:8161 + managementEndpoint: my-broker-ss-0.my-broker-hdls-svc.arkmq.svc:8161 brokerName: amq-broker \ No newline at end of file
