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 505180dc7b ARTEMIS-5214 Ensuring stomp is loaded as a protocol on the
server
505180dc7b is described below
commit 505180dc7bbf36f0cf34e4e089ebcf4eecaa3169
Author: Clebert Suconic <[email protected]>
AuthorDate: Thu Dec 19 16:46:01 2024 -0500
ARTEMIS-5214 Ensuring stomp is loaded as a protocol on the server
I have seen a CI test failing once because the protocol was not loaded,
then I saw it failing all the time on my IDE.
This will ensure the protocol is always loaded.
---
.../apache/activemq/artemis/tests/integration/stomp/StompTestBase.java | 3 +++
1 file changed, 3 insertions(+)
diff --git
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/StompTestBase.java
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/StompTestBase.java
index 1f5deccef4..0418ad121b 100644
---
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/StompTestBase.java
+++
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/StompTestBase.java
@@ -45,6 +45,7 @@ import
org.apache.activemq.artemis.api.core.TransportConfiguration;
import org.apache.activemq.artemis.core.config.Configuration;
import org.apache.activemq.artemis.core.config.CoreAddressConfiguration;
import org.apache.activemq.artemis.core.protocol.stomp.Stomp;
+import
org.apache.activemq.artemis.core.protocol.stomp.StompProtocolManagerFactory;
import org.apache.activemq.artemis.core.remoting.impl.invm.InVMAcceptorFactory;
import
org.apache.activemq.artemis.core.remoting.impl.invm.InVMConnectorFactory;
import org.apache.activemq.artemis.core.remoting.impl.netty.TransportConstants;
@@ -204,6 +205,8 @@ public abstract class StompTestBase extends
ActiveMQTestBase {
config.setPersistenceEnabled(true);
ActiveMQServer activeMQServer =
addServer(ActiveMQServers.newActiveMQServer(config, defUser, defPass));
+ // make sure Stomp is loaded
+ activeMQServer.addProtocolManagerFactory(new
StompProtocolManagerFactory());
if (isSecurityEnabled()) {
ActiveMQJAASSecurityManager securityManager =
(ActiveMQJAASSecurityManager) activeMQServer.getSecurityManager();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
