This is an automated email from the ASF dual-hosted git repository.
fmariani pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new e4d04a14c5d CAMEL-22083: Use Plain Artemis Docker image by default
e4d04a14c5d is described below
commit e4d04a14c5da39f67b515d2fa0376dfbee299692
Author: Croway <federico.mariani.1...@gmail.com>
AuthorDate: Mon May 26 12:33:34 2025 +0200
CAMEL-22083: Use Plain Artemis Docker image by default
---
.../apache/camel/catalog/test-infra/metadata.json | 9 ++
.../src/generated/resources/META-INF/metadata.json | 9 ++
.../artemis/services/ArtemisAllInfraService.java | 100 +++++++++++++++++++++
3 files changed, 118 insertions(+)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/test-infra/metadata.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/test-infra/metadata.json
index c3ab636a89b..e7e1bfc7ce2 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/test-infra/metadata.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/test-infra/metadata.json
@@ -385,6 +385,15 @@
"groupId" : "org.apache.camel",
"artifactId" : "camel-test-infra-ollama",
"version" : "4.12.0-SNAPSHOT"
+}, {
+ "service" :
"org.apache.camel.test.infra.artemis.services.ArtemisInfraService",
+ "description" : "Apache Artemis is an open source message broker",
+ "implementation" :
"org.apache.camel.test.infra.artemis.services.ArtemisAllInfraService",
+ "alias" : [ "artemis" ],
+ "aliasImplementation" : [ ],
+ "groupId" : "org.apache.camel",
+ "artifactId" : "camel-test-infra-artemis",
+ "version" : "4.12.0-SNAPSHOT"
}, {
"service" :
"org.apache.camel.test.infra.azure.common.services.AzureInfraService",
"description" : "Local Azure services with Azurite",
diff --git
a/test-infra/camel-test-infra-all/src/generated/resources/META-INF/metadata.json
b/test-infra/camel-test-infra-all/src/generated/resources/META-INF/metadata.json
index c3ab636a89b..e7e1bfc7ce2 100644
---
a/test-infra/camel-test-infra-all/src/generated/resources/META-INF/metadata.json
+++
b/test-infra/camel-test-infra-all/src/generated/resources/META-INF/metadata.json
@@ -385,6 +385,15 @@
"groupId" : "org.apache.camel",
"artifactId" : "camel-test-infra-ollama",
"version" : "4.12.0-SNAPSHOT"
+}, {
+ "service" :
"org.apache.camel.test.infra.artemis.services.ArtemisInfraService",
+ "description" : "Apache Artemis is an open source message broker",
+ "implementation" :
"org.apache.camel.test.infra.artemis.services.ArtemisAllInfraService",
+ "alias" : [ "artemis" ],
+ "aliasImplementation" : [ ],
+ "groupId" : "org.apache.camel",
+ "artifactId" : "camel-test-infra-artemis",
+ "version" : "4.12.0-SNAPSHOT"
}, {
"service" :
"org.apache.camel.test.infra.azure.common.services.AzureInfraService",
"description" : "Local Azure services with Azurite",
diff --git
a/test-infra/camel-test-infra-artemis/src/main/java/org/apache/camel/test/infra/artemis/services/ArtemisAllInfraService.java
b/test-infra/camel-test-infra-artemis/src/main/java/org/apache/camel/test/infra/artemis/services/ArtemisAllInfraService.java
new file mode 100644
index 00000000000..8b2d446ec13
--- /dev/null
+++
b/test-infra/camel-test-infra-artemis/src/main/java/org/apache/camel/test/infra/artemis/services/ArtemisAllInfraService.java
@@ -0,0 +1,100 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.test.infra.artemis.services;
+
+import org.apache.activemq.artemis.core.server.QueueQueryResult;
+import org.apache.camel.spi.annotations.InfraService;
+import org.apache.camel.test.infra.common.services.ContainerService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@InfraService(service = ArtemisInfraService.class,
+ description = "Apache Artemis is an open source message broker",
+ serviceAlias = "artemis")
+public class ArtemisAllInfraService implements ArtemisInfraService,
ContainerService<ArtemisContainer> {
+ private static final Logger LOG =
LoggerFactory.getLogger(ArtemisAllInfraService.class);
+
+ private final ArtemisContainer container;
+
+ public ArtemisAllInfraService() {
+ container = initContainer();
+ }
+
+ protected ArtemisContainer initContainer() {
+ return new ArtemisContainer();
+ }
+
+ @Override
+ public String serviceAddress() {
+ return "tcp://localhost:" + brokerPort();
+ }
+
+ @Override
+ public String userName() {
+ return "artemis";
+ }
+
+ @Override
+ public String password() {
+ return "artemis";
+ }
+
+ @Override
+ public int brokerPort() {
+ return container.getMappedPort(61616);
+ }
+
+ @Override
+ public void restart() {
+
+ }
+
+ @Override
+ public long countMessages(String queue) throws Exception {
+ return 0;
+ }
+
+ @Override
+ public QueueQueryResult getQueueQueryResult(String queueQuery) throws
Exception {
+ return null;
+ }
+
+ @Override
+ public void initialize() {
+ LOG.info("Trying to start the Artemis container");
+ container.start();
+
+ registerProperties();
+ LOG.info("Artemis instance running at {}", serviceAddress());
+ }
+
+ @Override
+ public void shutdown() {
+ LOG.info("Stopping the Artemis container");
+ container.stop();
+ }
+
+ @Override
+ public ArtemisContainer getContainer() {
+ return container;
+ }
+
+ @Override
+ public String remoteURI() {
+ return serviceAddress();
+ }
+}
