NO-JIRA Fix NettyConnectorWithHTTPUpgradeTest

This commit is contained in:
Domenico Francesco Bruscino 2021-03-24 19:36:31 +01:00 committed by clebertsuconic
parent 186481bbe8
commit e45c1d98d4
1 changed files with 5 additions and 5 deletions

View File

@ -123,12 +123,12 @@ public class NettyConnectorWithHTTPUpgradeTest extends ActiveMQTestBase {
server.start(); server.start();
HashMap<String, Object> httpConnectorParams = new HashMap<>(); HashMap<String, Object> httpConnectorParams = new HashMap<>();
httpAcceptorParams.put(TransportConstants.HTTP_UPGRADE_ENABLED_PROP_NAME, true); httpConnectorParams.put(TransportConstants.HTTP_UPGRADE_ENABLED_PROP_NAME, true);
httpAcceptorParams.put(TransportConstants.PORT_PROP_NAME, HTTP_PORT); httpConnectorParams.put(TransportConstants.PORT_PROP_NAME, HTTP_PORT);
if (useSSL) { if (useSSL) {
httpAcceptorParams.put(TransportConstants.SSL_ENABLED_PROP_NAME, true); httpConnectorParams.put(TransportConstants.SSL_ENABLED_PROP_NAME, true);
httpAcceptorParams.put(TransportConstants.TRUSTSTORE_PATH_PROP_NAME, CLIENT_SIDE_TRUSTSTORE); httpConnectorParams.put(TransportConstants.TRUSTSTORE_PATH_PROP_NAME, CLIENT_SIDE_TRUSTSTORE);
httpAcceptorParams.put(TransportConstants.TRUSTSTORE_PASSWORD_PROP_NAME, PASSWORD); httpConnectorParams.put(TransportConstants.TRUSTSTORE_PASSWORD_PROP_NAME, PASSWORD);
} }
locator = ActiveMQClient.createServerLocatorWithoutHA(new TransportConfiguration(NETTY_CONNECTOR_FACTORY, httpConnectorParams)); locator = ActiveMQClient.createServerLocatorWithoutHA(new TransportConfiguration(NETTY_CONNECTOR_FACTORY, httpConnectorParams));
addServerLocator(locator); addServerLocator(locator);