You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2021/03/24 23:05:16 UTC

[activemq-artemis] branch master updated: NO-JIRA Fix NettyConnectorWithHTTPUpgradeTest

This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/master by this push:
     new e45c1d9  NO-JIRA Fix NettyConnectorWithHTTPUpgradeTest
e45c1d9 is described below

commit e45c1d98d4768a0a37b319d1df107d6c32142919
Author: Domenico Francesco Bruscino <br...@apache.org>
AuthorDate: Wed Mar 24 19:36:31 2021 +0100

    NO-JIRA Fix NettyConnectorWithHTTPUpgradeTest
---
 .../transports/netty/NettyConnectorWithHTTPUpgradeTest.java    | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/transports/netty/NettyConnectorWithHTTPUpgradeTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/transports/netty/NettyConnectorWithHTTPUpgradeTest.java
index 986d610..92aab6d 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/transports/netty/NettyConnectorWithHTTPUpgradeTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/transports/netty/NettyConnectorWithHTTPUpgradeTest.java
@@ -123,12 +123,12 @@ public class NettyConnectorWithHTTPUpgradeTest extends ActiveMQTestBase {
       server.start();
 
       HashMap<String, Object> httpConnectorParams = new HashMap<>();
-      httpAcceptorParams.put(TransportConstants.HTTP_UPGRADE_ENABLED_PROP_NAME, true);
-      httpAcceptorParams.put(TransportConstants.PORT_PROP_NAME, HTTP_PORT);
+      httpConnectorParams.put(TransportConstants.HTTP_UPGRADE_ENABLED_PROP_NAME, true);
+      httpConnectorParams.put(TransportConstants.PORT_PROP_NAME, HTTP_PORT);
       if (useSSL) {
-         httpAcceptorParams.put(TransportConstants.SSL_ENABLED_PROP_NAME, true);
-         httpAcceptorParams.put(TransportConstants.TRUSTSTORE_PATH_PROP_NAME, CLIENT_SIDE_TRUSTSTORE);
-         httpAcceptorParams.put(TransportConstants.TRUSTSTORE_PASSWORD_PROP_NAME, PASSWORD);
+         httpConnectorParams.put(TransportConstants.SSL_ENABLED_PROP_NAME, true);
+         httpConnectorParams.put(TransportConstants.TRUSTSTORE_PATH_PROP_NAME, CLIENT_SIDE_TRUSTSTORE);
+         httpConnectorParams.put(TransportConstants.TRUSTSTORE_PASSWORD_PROP_NAME, PASSWORD);
       }
       locator = ActiveMQClient.createServerLocatorWithoutHA(new TransportConfiguration(NETTY_CONNECTOR_FACTORY, httpConnectorParams));
       addServerLocator(locator);