You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2023/06/07 05:36:25 UTC
[camel] 01/02: (chores) camel-test-infra-artemis: prevent blocking the tests on disk full
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit dd18711c75992f6d8e279c1a260c1f5b56ff2739
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Jun 6 17:24:08 2023 +0200
(chores) camel-test-infra-artemis: prevent blocking the tests on disk full
---
.../camel/test/infra/artemis/services/ArtemisPersistentVMService.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/test-infra/camel-test-infra-artemis/src/test/java/org/apache/camel/test/infra/artemis/services/ArtemisPersistentVMService.java b/test-infra/camel-test-infra-artemis/src/test/java/org/apache/camel/test/infra/artemis/services/ArtemisPersistentVMService.java
index db0bbd36a2b..c042f56c255 100644
--- a/test-infra/camel-test-infra-artemis/src/test/java/org/apache/camel/test/infra/artemis/services/ArtemisPersistentVMService.java
+++ b/test-infra/camel-test-infra-artemis/src/test/java/org/apache/camel/test/infra/artemis/services/ArtemisPersistentVMService.java
@@ -19,6 +19,7 @@ package org.apache.camel.test.infra.artemis.services;
import org.apache.activemq.artemis.api.core.SimpleString;
import org.apache.activemq.artemis.core.config.Configuration;
import org.apache.activemq.artemis.core.server.JournalType;
+import org.apache.activemq.artemis.core.settings.impl.AddressFullMessagePolicy;
import org.apache.activemq.artemis.core.settings.impl.AddressSettings;
import static org.junit.jupiter.api.Assertions.fail;
@@ -35,6 +36,7 @@ public class ArtemisPersistentVMService extends AbstractArtemisEmbeddedService {
configuration.setPersistenceEnabled(true);
configuration.setJournalType(JournalType.NIO);
+
try {
configuration.addAcceptorConfiguration("in-vm", brokerURL);
} catch (Exception e) {
@@ -43,6 +45,7 @@ public class ArtemisPersistentVMService extends AbstractArtemisEmbeddedService {
}
configuration.addAddressSetting("#",
new AddressSettings()
+ .setAddressFullMessagePolicy(AddressFullMessagePolicy.FAIL)
.setDeadLetterAddress(SimpleString.toSimpleString("DLQ"))
.setExpiryAddress(SimpleString.toSimpleString("ExpiryQueue")));