• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号
登陆 注册
描述文字

Java ManagementClient类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.jboss.as.arquillian.container.ManagementClient类的典型用法代码示例。如果您正苦于以下问题：Java ManagementClient类的具体用法？Java ManagementClient怎么用？Java ManagementClient使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



ManagementClient类属于org.jboss.as.arquillian.container包，在下文中一共展示了ManagementClient类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: setup

import org.jboss.as.arquillian.container.ManagementClient; //导入依赖的package包/类
@Override
public void setup(final ManagementClient managementClient, final String containerId) throws Exception {
	final ServerDeploymentManager manager = ServerDeploymentManager.Factory
			.create(managementClient.getControllerClient());
	final DeploymentPlan plan = manager.newDeploymentPlan()
			.add(new File("src/test/resources/isolations/" + TEST_DS_XML)).andDeploy().build();
	final Future<ServerDeploymentPlanResult> future = manager.execute(plan);
	final ServerDeploymentPlanResult result = future.get(20, SECONDS);
	final ServerDeploymentActionResult actionResult = result.getDeploymentActionResult(plan.getId());
	if (actionResult != null) {
		final Throwable deploymentException = actionResult.getDeploymentException();
		if (deploymentException != null) {
			throw new RuntimeException(deploymentException);
		}
	}
}
开发者ID:PacktPublishing，项目名称:Mastering-Java-EE-Development-with-WildFly，代码行数:17，代码来源:ReadUncommittedTestCase.java


示例2: setup

import org.jboss.as.arquillian.container.ManagementClient; //导入依赖的package包/类
@Override
public void setup(final ManagementClient managementClient, final String containerId) throws Exception {
	final ServerDeploymentManager manager = ServerDeploymentManager.Factory
			.create(managementClient.getControllerClient());
	final DeploymentPlan plan = manager.newDeploymentPlan()
			.add(new File("src/test/resources/distributed/" + TEXTS_DS_XML)).andDeploy().build();
	final Future<ServerDeploymentPlanResult> future = manager.execute(plan);
	final ServerDeploymentPlanResult result = future.get(20, SECONDS);
	final ServerDeploymentActionResult actionResult = result.getDeploymentActionResult(plan.getId());
	if (actionResult != null) {
		final Throwable deploymentException = actionResult.getDeploymentException();
		if (deploymentException != null) {
			throw new RuntimeException(deploymentException);
		}
	}
}
开发者ID:PacktPublishing，项目名称:Mastering-Java-EE-Development-with-WildFly，代码行数:17，代码来源:DistributedTestCase.java


示例3: setup

import org.jboss.as.arquillian.container.ManagementClient; //导入依赖的package包/类
@Override
public void setup(final ManagementClient managementClient, final String containerId) throws Exception {
	copy(new File("src/test/resources/application-users.properties").toPath(),
			new File("target/wildfly-10.1.0.Final/standalone/configuration/application-users.properties")
					.toPath(),
			REPLACE_EXISTING);
	copy(new File("src/test/resources/application-roles.properties").toPath(),
			new File("target/wildfly-10.1.0.Final/standalone/configuration/application-roles.properties")
					.toPath(),
			REPLACE_EXISTING);
	final ServerDeploymentManager manager = ServerDeploymentManager.Factory
			.create(managementClient.getControllerClient());
	final DeploymentPlan plan = manager.newDeploymentPlan().add(new File("src/test/resources/" + FORUMS_DS_XML))
			.andDeploy().build();
	final Future<ServerDeploymentPlanResult> future = manager.execute(plan);
	final ServerDeploymentPlanResult result = future.get(20, SECONDS);
	final ServerDeploymentActionResult actionResult = result.getDeploymentActionResult(plan.getId());
	if (actionResult != null) {
		final Throwable deploymentException = actionResult.getDeploymentException();
		if (deploymentException != null) {
			throw new RuntimeException(deploymentException);
		}
	}
}
开发者ID:PacktPublishing，项目名称:Mastering-Java-EE-Development-with-WildFly，代码行数:25，代码来源:ApplicationTestCase.java


示例4: setup

import org.jboss.as.arquillian.container.ManagementClient; //导入依赖的package包/类
@Override
public final void setup(final ManagementClient managementClient, final String containerId) throws Exception {
    setManagementClient(managementClient);
    ModelNode address = new ModelNode();
    address.add("subsystem", "neo4j");
    address.add("neo4j", "default");
    address.protect();

    final ModelNode operation = new ModelNode();
    operation.get(OP_ADDR).set(address);
    operation.get(OP).set(WRITE_ATTRIBUTE_OPERATION);
    operation.get(NAME).set("module");
    operation.get(VALUE).set("org.neo4j.driver:test");
    ModelNode result = executeOperation(operation);
    reload();
}
开发者ID:wildfly，项目名称:wildfly-nosql，代码行数:17，代码来源:CustomModuleTestCase.java


示例5: setup

import org.jboss.as.arquillian.container.ManagementClient; //导入依赖的package包/类
@Override
public final void setup(final ManagementClient managementClient, final String containerId) throws Exception {
    setManagementClient(managementClient);
    ModelNode address = new ModelNode();
    address.add("subsystem", "orientdb");
    address.add("orient", "default");
    address.protect();

    final ModelNode operation = new ModelNode();
    operation.get(OP_ADDR).set(address);
    operation.get(OP).set(WRITE_ATTRIBUTE_OPERATION);
    operation.get(NAME).set("module");
    operation.get(VALUE).set("com.orientechnologies:test");
    ModelNode result = executeOperation(operation);
    reload();
}
开发者ID:wildfly，项目名称:wildfly-nosql，代码行数:17，代码来源:CustomModuleTestCase.java


示例6: setup

import org.jboss.as.arquillian.container.ManagementClient; //导入依赖的package包/类
@Override
public final void setup(final ManagementClient managementClient, final String containerId) throws Exception {
    setManagementClient(managementClient);
    ModelNode address = new ModelNode();
    address.add("subsystem", "cassandra");
    address.add("cassandra", "default");
    address.protect();

    final ModelNode operation = new ModelNode();
    operation.get(OP_ADDR).set(address);
    operation.get(OP).set(WRITE_ATTRIBUTE_OPERATION);
    operation.get(NAME).set("module");
    operation.get(VALUE).set("com.datastax.cassandra.driver-core:test");
    ModelNode result = executeOperation(operation);
    reload();
}
开发者ID:wildfly，项目名称:wildfly-nosql，代码行数:17，代码来源:CustomModuleTestCase.java


示例7: setup

import org.jboss.as.arquillian.container.ManagementClient; //导入依赖的package包/类
@Override
public final void setup(final ManagementClient managementClient, final String containerId) throws Exception {
    setManagementClient(managementClient);
    ModelNode address = new ModelNode();
    address.add("subsystem", "mongodb");
    address.add("mongo", "default");
    address.protect();

    final ModelNode operation = new ModelNode();
    operation.get(OP_ADDR).set(address);
    operation.get(OP).set(WRITE_ATTRIBUTE_OPERATION);
    operation.get(NAME).set("module");
    operation.get(VALUE).set("org.mongodb.driver:test");
    ModelNode result = executeOperation(operation);
    reload();
}
开发者ID:wildfly，项目名称:wildfly-nosql，代码行数:17，代码来源:CustomModuleTestCase.java


示例8: tearDown

import org.jboss.as.arquillian.container.ManagementClient; //导入依赖的package包/类
@Override
public void tearDown(ManagementClient managementClient, String containerId) throws Exception {
    ModelNode[] steps = new ModelNode[5];
    steps[0] = DMRUtils.createOpNode(ADDRESS_SUBSYSTEM_UNDERTOW_HTTPS_LISTENER, ModelDescriptionConstants.UNDEFINE_ATTRIBUTE_OPERATION);
    steps[0].get(ModelDescriptionConstants.NAME).set("verify-client");

    steps[1] = DMRUtils.createOpNode(ADDRESS_SUBSYSTEM_SECURITY_SECURITY_DOMAIN_CLIENT_CERT, ModelDescriptionConstants.REMOVE);

    steps[2] = DMRUtils.createOpNode(ADDRESS_SUBSYSTEM_SECURITY_SECURITY_DOMAIN_CERTIFICATE_TRUST_DOMAIN, ModelDescriptionConstants.REMOVE);

    steps[3] = DMRUtils.createOpNode(ADDRESS_SYSTEM_PROPERTY_TRUST_STORE, ModelDescriptionConstants.REMOVE);
    steps[4] = DMRUtils.createOpNode(ADDRESS_SYSTEM_PROPERTY_TRUST_STORE_PASSWORD, ModelDescriptionConstants.REMOVE);

    ModelNode compositeNode = DMRUtils.createCompositeNode(steps);
    managementClient.getControllerClient().execute(compositeNode);

    UserManager.removeApplicationUser(APPLICATION_USER);
    UserManager.revokeRoleFromApplicationUser(APPLICATION_USER, APPLICATION_ROLE);
}
开发者ID:wildfly-extras，项目名称:wildfly-camel-examples，代码行数:20，代码来源:CxfWsCdiSecureExampleTest.java


示例9: setup

import org.jboss.as.arquillian.container.ManagementClient; //导入依赖的package包/类
@Override
public void setup(ManagementClient client, String unused) throws Exception {
    ModelNode op = new ModelNode();
    op.get("operation").set("add");
    op.get("address").add("subsystem", "security");
    op.get("address").add("security-domain", "netty-security-cert");
    op.get("cache-type").set("default");
    client.getControllerClient().execute(op);

    op.remove("cache-type");
    op.get("address").add("authentication", "classic");
    ModelNode loginModule = new ModelNode();
    loginModule.get("code").set("org.switchyard.security.login.CertificateLoginModule");
    loginModule.get("flag").set("required");
    loginModule.get("module-options").add("keyStoreLocation",
            new File(SRC_DIR, "users.jks").getAbsolutePath());
    loginModule.get("module-options").add("keyStorePassword", "changeit");
    loginModule.get("module-options").add("rolesProperties",
            new File(SRC_DIR, "roles.properties").getAbsolutePath());
    op.get("login-modules").add(loginModule);
    op.get("operation-headers", "allow-resource-service-restart").set("true");
    client.getControllerClient().execute(op);
    
    Thread.sleep(1000);
}
开发者ID:jboss-switchyard，项目名称:switchyard，代码行数:26，代码来源:CamelNettyBindingQuickstartTest.java


示例10: tearDown

import org.jboss.as.arquillian.container.ManagementClient; //导入依赖的package包/类
@Override
public void tearDown(ManagementClient client, String unused) throws Exception {
    ResourceDeployer.tearDownSSL(client);

    ModelNode op = new ModelNode();
    op.get("operation").set("remove");
    op.get("address").add("subsystem", "security");
    op.get("address").add("security-domain", "picketlink-sts");
    client.getControllerClient().execute(op);

    op = new ModelNode();
    op.get("operation").set("remove");
    op.get("address").add("subsystem", "security");
    op.get("address").add("security-domain", "saml-validate-token");
    client.getControllerClient().execute(op);
}
开发者ID:jboss-switchyard，项目名称:switchyard，代码行数:17，代码来源:PolicySecuritySamlDemoQuickstartTest.java


示例11: tearDownSSL

import org.jboss.as.arquillian.container.ManagementClient; //导入依赖的package包/类
public static void tearDownSSL(ManagementClient client) throws Exception {
    // EAP
    ModelNode op = new ModelNode();
    op.get("operation").set("remove");
    op.get("address").add("subsystem", "web");
    op.get("address").add("connector", "https");
    client.getControllerClient().execute(op);

    // WildFly
    op = new ModelNode();
    op.get("operation").set("remove");
    op.get("address").add("subsystem", "undertow");
    op.get("address").add("server", "default-server");
    op.get("address").add("https-listener", "https");
    client.getControllerClient().execute(op);

    op = new ModelNode();
    op.get("operation").set("remove");
    op.get("address").add("core-service", "management");
    op.get("address").add("security-realm", "SslRealm");
    client.getControllerClient().execute(op);
}
开发者ID:jboss-switchyard，项目名称:switchyard，代码行数:23，代码来源:ResourceDeployer.java


示例12: testDeploy

import org.jboss.as.arquillian.container.ManagementClient; //导入依赖的package包/类
private static void testDeploy(final ArchiveDeployer deployer, final ManagementClient client, final String containerName) throws IOException, DeploymentException {
    if (!controller.isStarted(containerName)) {
        controller.start(containerName);
    }
    final int currentDeployments = getCurrentDeploymentCount(client);
    // Deploy both deployments
    try {
        deployer.deploy(createDeployment());
        // Read each result, we should have two results for the first op and one for the second
        final int newDeployments = getCurrentDeploymentCount(client);
        Assert.assertTrue("Expected 1 deployments found " + (newDeployments - currentDeployments) + " for container " + containerName,
                newDeployments == (1 + currentDeployments));
    } finally {
        deployer.undeploy("dep1");
        controller.stop(containerName);
    }
}
开发者ID:wildfly，项目名称:wildfly-arquillian，代码行数:18，代码来源:ClientManualModeTestCase.java


示例13: setup

import org.jboss.as.arquillian.container.ManagementClient; //导入依赖的package包/类
@Override
public void setup(final ManagementClient managementClient, String containerId) throws Exception {
    String contextXml = "" +
            "\t\t     <route>\n" +
            "\t\t       <from uri=\"direct:start\"/>\n" +
            "\t\t       <transform>\n" +
            "\t\t         <simple>Hello #{body}</simple>\n" +
            "\t\t       </transform>\n" +
            "\t\t     </route>\n" +
            "";

    // Add a system context
    ModelNode contextOpAdd = DMRUtils.createOpNode("subsystem=camel/context=jmx-context-1/", "add");
    contextOpAdd.get("value").set(contextXml);
    managementClient.getControllerClient().execute(DMRUtils.createCompositeNode(new ModelNode[]{contextOpAdd}));
}
开发者ID:wildfly-extras，项目名称:wildfly-camel，代码行数:17，代码来源:JMXIntegrationTest.java


示例14: setup

import org.jboss.as.arquillian.container.ManagementClient; //导入依赖的package包/类
@Override
public void setup(ManagementClient managementClient, String containerId) throws Exception {
    // Set up a security domain for our tests to authenticate against
    ModelNode securityDomainOpAdd = DMRUtils.createOpNode("subsystem=security/security-domain=cxf-security-domain", "add");
    ModelNode securityDomainContent = DMRUtils.createOpNode("subsystem=security/security-domain=cxf-security-domain/authentication=classic", "add");

    ModelNode loginModules = securityDomainContent.get("login-modules");

    ModelNode userRoles = new ModelNode();
    userRoles.get("code").set("UsersRoles");
    userRoles.get("flag").set("required");

    ModelNode moduleOptions = userRoles.get("module-options");
    moduleOptions.get("usersProperties").set("cxf-users.properties");
    moduleOptions.get("rolesProperties").set("cxf-roles.properties");
    loginModules.add(userRoles);

    ModelNode result = managementClient.getControllerClient().execute(DMRUtils.createCompositeNode(new ModelNode[]{securityDomainOpAdd, securityDomainContent}));

    // Make sure the commands worked before proceeding
    Assert.assertEquals("success", result.get("outcome").asString());
}
开发者ID:wildfly-extras，项目名称:wildfly-camel，代码行数:23，代码来源:CXFWSSecureProducerIntegrationTest.java


示例15: setup

import org.jboss.as.arquillian.container.ManagementClient; //导入依赖的package包/类
@Override
public void setup(ManagementClient managementClient, String containerId) throws Exception {
    int port = AvailablePortFinder.getNextAvailable();
    AvailablePortFinder.storeServerData("rabbitmq-port", port);

    String jbossHome = System.getProperty("jboss.home.dir");

    Path workPath = Paths.get(jbossHome, "standalone", "data", "rabbitmq");
    Path configPath = Paths.get(jbossHome, "standalone", "configuration", "rabbitmq");
    Path qpidConfig = configPath.resolve("qpid-config.json");
    configPath.toFile().mkdir();

    BrokerOptions brokerOptions = new BrokerOptions();
    brokerOptions.setConfigProperty("qpid.amqp_port", String.valueOf(port));
    brokerOptions.setConfigProperty("qpid.user", RABBITMQ_USERNAME);
    brokerOptions.setConfigProperty("qpid.password", RABBITMQ_PASSWORD);
    brokerOptions.setConfigProperty("qpid.work_dir", workPath.toString());
    brokerOptions.setInitialConfigurationLocation(qpidConfig.toString());

    Files.copy(RabbitMQIntegrationTest.class.getResourceAsStream("/rabbitmq/qpid-config.json"), qpidConfig, StandardCopyOption.REPLACE_EXISTING);

    broker.startup(brokerOptions);
}
开发者ID:wildfly-extras，项目名称:wildfly-camel，代码行数:24，代码来源:RabbitMQIntegrationTest.java


示例16: setup

import org.jboss.as.arquillian.container.ManagementClient; //导入依赖的package包/类
@Override
public void setup(ManagementClient managementClient, String containerId) throws Exception {

    CommandContext commandContext = CommandContextFactory.getInstance().newCommandContext();
    commandContext.bindClient(managementClient.getControllerClient());
    commandContext
            .handle("/subsystem=logging/custom-formatter=JsonFormatter/:add(module=biz.paluch.logging,class=biz.paluch.logging.gelf.wildfly.WildFlyJsonFormatter,properties={ \\\n"
                    + "\t\t   version=\"1.0\", \\\n" + "\t\t   facility=\"java-test\", \\\n"
                    + "\t\t   extractStackTrace=true, \\\n" + "\t\t   filterStackTrace=true, \\\n"
                    + "\t\t   mdcProfiling=true, \\\n"
                    + "\t\t   additionalFields=\"fieldName1=fieldValue1,fieldName2=fieldValue2\", \\\n"
                    + "\t\t   mdcFields=\"mdcField1,mdcField2\"})");

    commandContext
            .handle("/subsystem=logging/file-handler=JsonLog/:add(file={\"relative-to\"=>\"jboss.server.log.dir\" ,path=server.json}, \\\n"
                    + "            level=ALL,named-formatter=JsonFormatter)");

    commandContext.handle(
            "/subsystem=logging/root-logger=ROOT/:write-attribute(name=handlers,value=[\"FILE\",\"CONSOLE\",\"JsonLog\"])");
}
开发者ID:mp911de，项目名称:logstash-gelf，代码行数:21，代码来源:WildFlyFormatterIntegrationTests.java


示例17: setup

import org.jboss.as.arquillian.container.ManagementClient; //导入依赖的package包/类
@Override
public void setup(ManagementClient managementClient, String containerId) throws Exception {

    CommandContext commandContext = CommandContextFactory.getInstance().newCommandContext();
    commandContext.bindClient(managementClient.getControllerClient());
    commandContext
            .handle("/subsystem=logging/custom-handler=GelfLogger/:add(module=biz.paluch.logging,class=biz.paluch.logging.gelf.wildfly.WildFlyGelfLogHandler,properties={ \\\n"
                    + "           host=\"udp:localhost\", \\\n" + "           port=\"19392\", \\\n"
                    + "           version=\"1.0\", \\\n" + "\t\t   facility=\"java-test\", \\\n"
                    + "\t\t   extractStackTrace=true, \\\n" + "\t\t   filterStackTrace=true, \\\n"
                    + "\t\t   mdcProfiling=true, \\\n" + "\t\t   timestampPattern=\"yyyy-MM-dd HH:mm:ss,SSSS\", \\\n"
                    + "\t\t   maximumMessageSize=8192, \\\n"
                    + "\t\t   additionalFields=\"fieldName1=fieldValue1,fieldName2=fieldValue2\", \\\n"
                    + "\t\t   mdcFields=\"mdcField1,mdcField2\" \\\n"
                    + "\t\t   dynamicMdcFields=\"mdc.*,(mdc|MDC)fields\" \\\n" + "\t\t   includeFullMdc=true \\\n"
                    + "    })");

    commandContext.handle(
            "/subsystem=logging/root-logger=ROOT/:write-attribute(name=handlers,value=[\"FILE\",\"CONSOLE\",\"GelfLogger\"])");
}
开发者ID:mp911de，项目名称:logstash-gelf，代码行数:21，代码来源:WildFlyHandlerIntegrationTests.java


示例18: setup

import org.jboss.as.arquillian.container.ManagementClient; //导入依赖的package包/类
@Override
public void setup(ManagementClient managementClient, String containerId) throws Exception {
	copy(new File("src/test/resources/application-users.properties").toPath(),
			new File("target/wildfly-10.1.0.Final/standalone/configuration/application-users.properties")
					.toPath(),
			REPLACE_EXISTING);
	copy(new File("src/test/resources/application-roles.properties").toPath(),
			new File("target/wildfly-10.1.0.Final/standalone/configuration/application-roles.properties")
					.toPath(),
			REPLACE_EXISTING);
	ModelControllerClient modelControllerClient = managementClient.getControllerClient();
	JMSOperations jmsOperations = getInstance(modelControllerClient);
	jmsOperations.createJmsQueue(REMOTE_QUEUE_NAME, REMOTE_EXPORTED_QUEUE_LOOKUP);
}
开发者ID:PacktPublishing，项目名称:Mastering-Java-EE-Development-with-WildFly，代码行数:15，代码来源:RemoteTestCase.java


示例19: tearDown

import org.jboss.as.arquillian.container.ManagementClient; //导入依赖的package包/类
@Override
public void tearDown(final ManagementClient managementClient, final String containerId) throws Exception {
	final ServerDeploymentManager manager = ServerDeploymentManager.Factory
			.create(managementClient.getControllerClient());
	final DeploymentPlan undeployPlan = manager.newDeploymentPlan().undeploy(TEST_DS_XML).andRemoveUndeployed()
			.build();
	manager.execute(undeployPlan).get();
}
开发者ID:PacktPublishing，项目名称:Mastering-Java-EE-Development-with-WildFly，代码行数:9，代码来源:ReadUncommittedTestCase.java


示例20: tearDown

import org.jboss.as.arquillian.container.ManagementClient; //导入依赖的package包/类
@Override
public void tearDown(final ManagementClient managementClient, final String containerId) throws Exception {
	final ServerDeploymentManager manager = ServerDeploymentManager.Factory
			.create(managementClient.getControllerClient());
	final DeploymentPlan undeployPlan = manager.newDeploymentPlan().undeploy(TEXTS_DS_XML).andRemoveUndeployed()
			.build();
	manager.execute(undeployPlan).get();
}
开发者ID:PacktPublishing，项目名称:Mastering-Java-EE-Development-with-WildFly，代码行数:9，代码来源:DistributedTestCase.java



注：本文中的org.jboss.as.arquillian.container.ManagementClient类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花
握手
雷人
路过
鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
More+
上一篇：
Java DescribeStacksRequest类代码示例发布时间：2022-05-23
下一篇：
Java BlockRedstoneOre类代码示例发布时间：2022-05-23
热门推荐
More+
热门话题
More+
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服（服务时间 9:00～18:00）

在线QQ客服
地址：深圳市南山区西丽大学城创智工业园
电邮：jeky_zhao#qq.com
移动电话：139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap