[camel] 01/02: (chores) camel-test-infra-artemis: prevent blocking the tests on disk full

[orpiske]

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 <angusyo...@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")));