Package org.jboss.dmr

Examples of org.jboss.dmr.ModelNode.asString()

344
345
346
347
348
349
350
351
352
353
354
        ModelNode returnVal = validateResponse(response);
        Assert.assertTrue(hasTestSchemaLocation(returnVal));

        response = masterClient.execute(getReadAttributeOperation(TEST_SERVER_GROUP_ADDRESS, PROFILE));
        returnVal = validateResponse(response);
        Assert.assertEquals("default", returnVal.asString());

        // Slave can't write
        response = slaveClient.execute(masterRequest);
        validateFailedResponse(response);
    }
View Full Code Here
117
118
119
120
121
122
123
124
125
126
127
        operation.get(OP).set(READ_ATTRIBUTE_OPERATION);
        operation.get(OP_ADDR).set(mainOne);
        operation.get(NAME).set("status");

        final ModelNode status = validateResponse(client.execute(operation));
        Assert.assertEquals("STARTED", status.asString());

        final ModelNode remove = new ModelNode();
        remove.get(OP).set(REMOVE);
        remove.get(OP_ADDR).set(mainOne);
View Full Code Here
146
147
148
149
150
151
152
153
154
155
156
            final ModelNode serverOne = new ModelNode();
            serverOne.add(HOST, "master");
            serverOne.add(RUNNING_SERVER, "reload-one");

            final ModelNode resultOne = getServerState(serverOne, client);
            Assert.assertEquals(RESTART_REQUIRED, resultOne.asString());

            // check the process state for reload-two
            final ModelNode serverTwo = new ModelNode();
            serverTwo.add(HOST, "slave");
            serverTwo.add(SERVER, "reload-two");
View Full Code Here
154
155
156
157
158
159
160
161
162
163
164
            final ModelNode serverTwo = new ModelNode();
            serverTwo.add(HOST, "slave");
            serverTwo.add(SERVER, "reload-two");

            final ModelNode resultTwo = getServerState(serverTwo, client);
            Assert.assertEquals(RESTART_REQUIRED, resultTwo.asString());

        } finally {
            //
        }
    }
View Full Code Here
337
338
339
340
341
342
343
344
345
346
347
        // take snapshot
        ModelNode op = ModelUtil.createOpNode(null, "take-snapshot");
        ModelNode result = executeOperation(client, op);
       
        // check that the snapshot file exists
        String snapshotFileName = result.asString();       
        File snapshotFile = new File(snapshotFileName);
        Assert.assertTrue(snapshotFile.exists());
       
        // compare with current cfg       
        long snapshotHash = FileUtils.checksumCRC32(snapshotFile);
View Full Code Here
436
437
438
439
440
441
442
443
444
445
446
                        final List<ScannerTask> retryTasks = new ArrayList<ScannerTask>();
                        for (int i = 0; i < resultList.size(); i++) {
                            final ModelNode result = resultList.get(i).getValue();
                            final ScannerTask task = scannerTasks.get(i);
                            final ModelNode outcome = result.get(OUTCOME);
                            if (outcome.isDefined() && SUCCESS.equals(outcome.asString())) {
                                task.handleSuccessResult();
                            } else if (outcome.isDefined() && CANCELLED.equals(outcome.asString())) {
                                toRetry.add(updates.get(i));
                                retryTasks.add(task);
                            } else {
View Full Code Here
438
439
440
441
442
443
444
445
446
447
448
                            final ModelNode result = resultList.get(i).getValue();
                            final ScannerTask task = scannerTasks.get(i);
                            final ModelNode outcome = result.get(OUTCOME);
                            if (outcome.isDefined() && SUCCESS.equals(outcome.asString())) {
                                task.handleSuccessResult();
                            } else if (outcome.isDefined() && CANCELLED.equals(outcome.asString())) {
                                toRetry.add(updates.get(i));
                                retryTasks.add(task);
                            } else {
                                task.handleFailureResult(result);
                            }
View Full Code Here
154
155
156
157
158
159
160
161
162
163
164
        }

        ServiceName realmSvcName = null;
        final ModelNode realmNode = SECURITY_REALM.resolveModelAttribute(context, model);
        if (realmNode.isDefined()) {
            realmSvcName = SecurityRealmService.BASE_SERVICE_NAME.append(realmNode.asString());
        } else {
            Logger.getLogger("org.jboss.as").warn("No security realm defined for native management service, all access will be unrestricted.");
        }

        ServiceName tmpDirPath = ServiceName.JBOSS.append("server", "path", "jboss.server.temp.dir");
View Full Code Here
113
114
115
116
117
118
119
120
121
122
123
                .addDependency(WebSubsystemServices.JBOSS_WEB, WebServer.class, service.getWebServer())
                .addDependency(SocketBindingManager.SOCKET_BINDING_MANAGER, SocketBindingManager.class, service.getBindingManager())
                .addListener(verificationHandler)
                .setInitialMode(Mode.ACTIVE);
        final ModelNode bindingRefNode = resolvedConfig.get(ModClusterConfigResourceDefinition.ADVERTISE_SOCKET.getName());
        final String bindingRef = bindingRefNode.isDefined() ? bindingRefNode.asString() : null;
         if (bindingRef != null) {
            serviceBuilder.addDependency(SocketBinding.JBOSS_BINDING_NAME.append(bindingRef), SocketBinding.class, service.getBinding());
         }

        newControllers.add(serviceBuilder.install());
View Full Code Here
364
365
366
367
368
369
370
371
372
373
374
                        final List<ScannerTask> retryTasks = new ArrayList<ScannerTask>();
                        for (int i = 0; i < resultList.size(); i++) {
                            final ModelNode result = resultList.get(i).getValue();
                            final ScannerTask task = scannerTasks.get(i);
                            final ModelNode outcome = result.get(OUTCOME);
                            if (outcome.isDefined() && SUCCESS.equals(outcome.asString())) {
                                task.handleSuccessResult();
                            } else if (outcome.isDefined() && CANCELLED.equals(outcome.asString())) {
                                toRetry.add(updates.get(i));
                                retryTasks.add(task);
                            } else {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.