This is an automated email from the ASF dual-hosted git repository.
clebertsuconic pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
The following commit(s) were added to refs/heads/main by this push:
new f66e9ade32 ARTEMIS-5556 initialize IO executor resources just once
f66e9ade32 is described below
commit f66e9ade326c29b25d9b305ae07bc2f867078041
Author: Justin Bertram <[email protected]>
AuthorDate: Fri Jun 27 11:38:01 2025 -0500
ARTEMIS-5556 initialize IO executor resources just once
There are no tests for this change. Basic inspection revealed the issue
and should suffice for validating the change.
---
.../activemq/artemis/core/server/impl/ActiveMQServerImpl.java | 9 ---------
1 file changed, 9 deletions(-)
diff --git
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
index af0cb8c664..04eb012a3c 100644
---
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
+++
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
@@ -3230,15 +3230,6 @@ public class ActiveMQServerImpl implements
ActiveMQServer {
this.ioExecutorFactory = new OrderedExecutorFactory(ioExecutorPool);
}
- if (serviceRegistry.getIOExecutorService() != null) {
- this.ioExecutorFactory = new
OrderedExecutorFactory(serviceRegistry.getIOExecutorService());
- } else {
- ThreadFactory tFactory =
AccessController.doPrivileged((PrivilegedAction<ThreadFactory>) () -> new
ActiveMQThreadFactory("ActiveMQ-IO-server-" + this, false,
ClientSessionFactoryImpl.class.getClassLoader()));
-
- this.ioExecutorPool = new ThreadPoolExecutor(0, Integer.MAX_VALUE,
60L, TimeUnit.SECONDS, new SynchronousQueue<>(), tFactory);
- this.ioExecutorFactory = new OrderedExecutorFactory(ioExecutorPool);
- }
-
if (serviceRegistry.getPageExecutorService() != null) {
this.pageExecutorFactory = new
OrderedExecutorFactory(serviceRegistry.getPageExecutorService()).setFair(true);
} else {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
