This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-4.22.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-4.22.x by this push:
new 703301876c8f [backport camel-4.22.x] CAMEL-25754:
camel-test-infra-artemis - no disk usage limit, so a broker on a nearly full
Docker disk does not block producers (#28096)
703301876c8f is described below
commit 703301876c8fe41a46209a057dc822a23f17b0cc
Author: Guillaume Nodet <[email protected]>
AuthorDate: Mon Oct 19 16:27:57 2026 +0200
[backport camel-4.22.x] CAMEL-25754: camel-test-infra-artemis - no disk
usage limit, so a broker on a nearly full Docker disk does not block producers
(#28096)
---
.../test/infra/artemis/services/AbstractArtemisEmbeddedService.java | 2 +-
.../camel/test/infra/artemis/services/ArtemisAMQPInfraService.java | 2 +-
.../org/apache/camel/test/infra/artemis/services/ArtemisContainer.java | 3 +++
.../camel/test/infra/artemis/services/ArtemisMQTTInfraService.java | 2 +-
.../test/infra/artemis/services/ArtemisPersistentVMInfraService.java | 2 +-
5 files changed, 7 insertions(+), 4 deletions(-)
diff --git
a/test-infra/camel-test-infra-artemis/src/main/java/org/apache/camel/test/infra/artemis/services/AbstractArtemisEmbeddedService.java
b/test-infra/camel-test-infra-artemis/src/main/java/org/apache/camel/test/infra/artemis/services/AbstractArtemisEmbeddedService.java
index ad6d7d746e8f..73095e2de80d 100644
---
a/test-infra/camel-test-infra-artemis/src/main/java/org/apache/camel/test/infra/artemis/services/AbstractArtemisEmbeddedService.java
+++
b/test-infra/camel-test-infra-artemis/src/main/java/org/apache/camel/test/infra/artemis/services/AbstractArtemisEmbeddedService.java
@@ -91,7 +91,7 @@ public abstract class AbstractArtemisEmbeddedService
implements ArtemisInfraServ
artemisConfiguration.setBrokerInstance(instanceDir);
artemisConfiguration.setJMXManagementEnabled(false);
- artemisConfiguration.setMaxDiskUsage(98);
+ artemisConfiguration.setMaxDiskUsage(-1);
final Configuration config = configure(artemisConfiguration, port,
brokerId);
if (customConfigurator != null) {
diff --git
a/test-infra/camel-test-infra-artemis/src/main/java/org/apache/camel/test/infra/artemis/services/ArtemisAMQPInfraService.java
b/test-infra/camel-test-infra-artemis/src/main/java/org/apache/camel/test/infra/artemis/services/ArtemisAMQPInfraService.java
index e8c518717018..2f5356571984 100644
---
a/test-infra/camel-test-infra-artemis/src/main/java/org/apache/camel/test/infra/artemis/services/ArtemisAMQPInfraService.java
+++
b/test-infra/camel-test-infra-artemis/src/main/java/org/apache/camel/test/infra/artemis/services/ArtemisAMQPInfraService.java
@@ -85,7 +85,7 @@ public class ArtemisAMQPInfraService extends
AbstractArtemisEmbeddedService {
roles.add(role);
artemisConfiguration.putSecurityRoles("#", roles);
}
- artemisConfiguration.setMaxDiskUsage(98);
+ artemisConfiguration.setMaxDiskUsage(-1);
// Set explicit topic name
CoreAddressConfiguration pingTopicConfig = new
CoreAddressConfiguration();
diff --git
a/test-infra/camel-test-infra-artemis/src/main/java/org/apache/camel/test/infra/artemis/services/ArtemisContainer.java
b/test-infra/camel-test-infra-artemis/src/main/java/org/apache/camel/test/infra/artemis/services/ArtemisContainer.java
index ea132dcc63da..ee4c5f83fa34 100644
---
a/test-infra/camel-test-infra-artemis/src/main/java/org/apache/camel/test/infra/artemis/services/ArtemisContainer.java
+++
b/test-infra/camel-test-infra-artemis/src/main/java/org/apache/camel/test/infra/artemis/services/ArtemisContainer.java
@@ -38,6 +38,9 @@ public class ArtemisContainer extends
GenericContainer<ArtemisContainer> impleme
.parse(LocalPropertyResolver.getProperty(ArtemisContainer.class,
ArtemisProperties.ARTEMIS_CONTAINER)));
this.withEnv("AMQ_EXTRA_ARGS", "--relax-jolokia")
+ // no disk usage limit: above 90% of the disk (the Docker VM
disk on a developer machine) the broker
+ // blocks every producer, and a route hangs on its send
(CAMEL-25754)
+ .withEnv("JAVA_ARGS_APPEND", "-Dbrokerconfig.maxDiskUsage=-1")
.withEnv("AMQ_USER", DEFAULT_USERNAME)
.withEnv("AMQ_PASSWORD", DEFAULT_PASSWORD)
.withExposedPorts(DEFAULT_MQTT_PORT, DEFAULT_AMQP_PORT,
diff --git
a/test-infra/camel-test-infra-artemis/src/main/java/org/apache/camel/test/infra/artemis/services/ArtemisMQTTInfraService.java
b/test-infra/camel-test-infra-artemis/src/main/java/org/apache/camel/test/infra/artemis/services/ArtemisMQTTInfraService.java
index 8317b02e3550..f77fc7c35014 100644
---
a/test-infra/camel-test-infra-artemis/src/main/java/org/apache/camel/test/infra/artemis/services/ArtemisMQTTInfraService.java
+++
b/test-infra/camel-test-infra-artemis/src/main/java/org/apache/camel/test/infra/artemis/services/ArtemisMQTTInfraService.java
@@ -46,7 +46,7 @@ public class ArtemisMQTTInfraService extends
AbstractArtemisEmbeddedService {
configuration.addAcceptorConfiguration("mqtt", brokerURL +
"?protocols=MQTT");
configuration.addAddressSetting("#", addressSettings);
- configuration.setMaxDiskUsage(98);
+ configuration.setMaxDiskUsage(-1);
} catch (Exception e) {
LOG.warn(e.getMessage(), e);
throw new ArtemisRunException("mqtt acceptor cannot be
configured", e);
diff --git
a/test-infra/camel-test-infra-artemis/src/main/java/org/apache/camel/test/infra/artemis/services/ArtemisPersistentVMInfraService.java
b/test-infra/camel-test-infra-artemis/src/main/java/org/apache/camel/test/infra/artemis/services/ArtemisPersistentVMInfraService.java
index 8fdf1ceb3100..f63f01dd0ea0 100644
---
a/test-infra/camel-test-infra-artemis/src/main/java/org/apache/camel/test/infra/artemis/services/ArtemisPersistentVMInfraService.java
+++
b/test-infra/camel-test-infra-artemis/src/main/java/org/apache/camel/test/infra/artemis/services/ArtemisPersistentVMInfraService.java
@@ -33,7 +33,7 @@ public class ArtemisPersistentVMInfraService extends
AbstractArtemisEmbeddedServ
configuration.setPersistenceEnabled(true);
configuration.setJournalType(JournalType.NIO);
- configuration.setMaxDiskUsage(98);
+ configuration.setMaxDiskUsage(-1);
try {
configuration.addAcceptorConfiguration("in-vm", brokerURL);
