This is an automated email from the ASF dual-hosted git repository.
hqtran pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
The following commit(s) were added to refs/heads/master by this push:
new 93c5bb2863 JAMES-4200 Allow configuring ActiveMQ disk and use sain
default of 10GB
93c5bb2863 is described below
commit 93c5bb2863c90bbf0a70f3043f669a7489cc0a48
Author: Benoit TELLIER <[email protected]>
AuthorDate: Sun Apr 12 07:43:22 2026 +0200
JAMES-4200 Allow configuring ActiveMQ disk and use sain default of 10GB
---
.../main/java/org/apache/james/queue/activemq/EmbeddedActiveMQ.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git
a/server/queue/queue-activemq/src/main/java/org/apache/james/queue/activemq/EmbeddedActiveMQ.java
b/server/queue/queue-activemq/src/main/java/org/apache/james/queue/activemq/EmbeddedActiveMQ.java
index afaddfd8dc..1871b05e66 100644
---
a/server/queue/queue-activemq/src/main/java/org/apache/james/queue/activemq/EmbeddedActiveMQ.java
+++
b/server/queue/queue-activemq/src/main/java/org/apache/james/queue/activemq/EmbeddedActiveMQ.java
@@ -44,6 +44,8 @@ public class EmbeddedActiveMQ {
private static final String BROKER_ID = "broker";
private static final String BROKER_NAME = "james";
private static final String BROCKER_URI = "tcp://localhost:0";
+ private static final String STORE_USAGE_LIMIT_PROPERTY =
"james.activemq.store.usage.limit.bytes";
+ private static final long DEFAULT_STORE_USAGE_LIMIT_BYTES = 10L * 1024 *
1024 * 1024; // 10 GB
private final ActiveMQConnectionFactory activeMQConnectionFactory;
private final PersistenceAdapter persistenceAdapter;
@@ -103,6 +105,8 @@ public class EmbeddedActiveMQ {
brokerService.setUseShutdownHook(false);
brokerService.setSchedulerSupport(false);
brokerService.setAdjustUsageLimits(false);
+ long storeUsageLimitBytes = Long.getLong(STORE_USAGE_LIMIT_PROPERTY,
DEFAULT_STORE_USAGE_LIMIT_BYTES);
+
brokerService.getSystemUsage().getStoreUsage().setLimit(storeUsageLimitBytes);
brokerService.setBrokerId(BROKER_ID);
String[] uris = {BROCKER_URI};
brokerService.setTransportConnectorURIs(uris);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
