Author: alessio.soldano(a)jboss.com Date: 2012-07-18 11:05:28 -0400 (Wed, 18 Jul 2012) New Revision: 16487 Modified: container/jboss71/branches/jbossws-jboss711/src/main/java/org/jboss/as/webservices/tests/RemoteDeployer.java Log: [JBWS-3446] Adding methods to AS 7.1.1 CI RemoteDeployer Modified: container/jboss71/branches/jbossws-jboss711/src/main/java/org/jboss/as/webservices/tests/RemoteDeployer.java =================================================================== --- container/jboss71/branches/jbossws-jboss711/src/main/java/org/jboss/as/webservices/tests/RemoteDeployer.java 2012-07-18 14:33:20 UTC (rev 16486) +++ container/jboss71/branches/jbossws-jboss711/src/main/java/org/jboss/as/webservices/tests/RemoteDeployer.java 2012-07-18 15:05:28 UTC (rev 16487) @@ -30,6 +30,7 @@ import java.util.HashMap; import java.util.List; import java.util.Map; +import java.util.concurrent.Semaphore; import javax.security.auth.callback.Callback; import javax.security.auth.callback.CallbackHandler; @@ -47,12 +48,14 @@ import org.jboss.as.controller.client.helpers.standalone.ServerDeploymentActionResult; import org.jboss.as.controller.client.helpers.standalone.ServerDeploymentManager; import org.jboss.as.controller.client.helpers.standalone.ServerDeploymentPlanResult; +import org.jboss.as.controller.operations.common.Util; import org.jboss.dmr.ModelNode; import org.jboss.logging.Logger; import org.jboss.wsf.spi.deployer.Deployer; import static org.jboss.as.controller.descriptions.ModelDescriptionConstants.ADD; import static org.jboss.as.controller.descriptions.ModelDescriptionConstants.ALLOW_RESOURCE_SERVICE_RESTART; +import static org.jboss.as.controller.descriptions.ModelDescriptionConstants.COMPOSITE; import static org.jboss.as.controller.descriptions.ModelDescriptionConstants.FAILURE_DESCRIPTION; import static org.jboss.as.controller.descriptions.ModelDescriptionConstants.NAME; import static org.jboss.as.controller.descriptions.ModelDescriptionConstants.OP; @@ -65,6 +68,7 @@ import static org.jboss.as.controller.descriptions.ModelDescriptionConstants.REQUIRED; import static org.jboss.as.controller.descriptions.ModelDescriptionConstants.RESULT; import static org.jboss.as.controller.descriptions.ModelDescriptionConstants.ROLLBACK_ON_RUNTIME_FAILURE; +import static org.jboss.as.controller.descriptions.ModelDescriptionConstants.STEPS; import static org.jboss.as.controller.descriptions.ModelDescriptionConstants.SUBSYSTEM; import static org.jboss.as.controller.descriptions.ModelDescriptionConstants.SUCCESS; import static org.jboss.as.security.Constants.AUTHENTICATION; @@ -98,6 +102,7 @@ private final ModelControllerClient modelControllerClient; private final Map<String, Integer> securityDomainUsers = new HashMap<String, Integer>(1); private final Map<String, Integer> archiveCounters = new HashMap<String, Integer>(); + private final Semaphore httpsConnSemaphore = new Semaphore(1); public RemoteDeployer() throws IOException { final String host = System.getProperty(JBWS_DEPLOYER_HOST); @@ -253,7 +258,44 @@ applyUpdate(op, getModelControllerClient()); } } + + @Override + public void addHttpsConnector(Map<String, String> sslOptions) throws Exception { + httpsConnSemaphore.acquire(); + try { + final ModelNode composite = Util.getEmptyOperation(COMPOSITE, new ModelNode()); + final ModelNode steps = composite.get(STEPS); + ModelNode op = createOpNode("subsystem=web/connector=jbws-test-https-connector", ADD); + op.get("socket-binding").set("https"); + op.get("scheme").set("https"); + op.get("protocol").set("HTTP/1.1"); + op.get("secure").set(true); + op.get("enabled").set(true); + steps.add(op); + ModelNode ssl = createOpNode("subsystem=web/connector=jbws-test-https-connector/ssl=configuration", ADD); + if (sslOptions != null) { + for (final String k : sslOptions.keySet()) { + ssl.get(k).set(sslOptions.get(k)); + } + } + steps.add(ssl); + applyUpdate(composite, getModelControllerClient()); + } catch (Exception e) { + httpsConnSemaphore.release(); + throw e; + } + } + @Override + public void removeHttpsConnector() throws Exception { + try { + ModelNode op = createOpNode("subsystem=web/connector=jbws-test-https-connector", REMOVE); + applyUpdate(op, getModelControllerClient()); + } finally { + httpsConnSemaphore.release(); + } + } + private ModelControllerClient getModelControllerClient() { return modelControllerClient; } @@ -313,6 +355,21 @@ } }; } + + public static ModelNode createOpNode(String address, String operation) { + ModelNode op = new ModelNode(); + // set address + ModelNode list = op.get("address").setEmptyList(); + if (address != null) { + String[] pathSegments = address.split("/"); + for (String segment : pathSegments) { + String[] elements = segment.split("="); + list.add(elements[0], elements[1]); + } + } + op.get("operation").set(operation); + return op; + } private static String getSystemProperty(final String name, final String defaultValue) { PrivilegedAction<String> action = new PrivilegedAction<String>() {