Examples of org.jboss.marshalling.Marshaller.start()

org.jboss.marshalling.Marshaller.start()
Begin marshalling to a stream. @param newOutput the new stream @throws IOException if an error occurs during setup, such as an error writing the header

        protected void sendResponse(final OutputStream output) throws IOException {


            List<DomainUpdateResult<?>> responses = domainController.applyUpdates(updates);


            final Marshaller marshaller = getMarshaller();
            marshaller.start(createByteOutput(output));
            marshaller.writeByte(DomainClientProtocol.RETURN_APPLY_UPDATES_RESULT_COUNT);
            marshaller.writeInt(responses.size());
            for (DomainUpdateResult<?> response : responses) {
                marshaller.writeByte(DomainClientProtocol.RETURN_APPLY_UPDATE);
                marshaller.writeObject(response);

View Full Code Here

        @Override
        protected void sendResponse(final OutputStream output) throws IOException {
            List<HostUpdateResult<?>> responses = domainController.applyHostUpdates(serverManagerName, updates);


            final Marshaller marshaller = getMarshaller();
            marshaller.start(createByteOutput(output));
            marshaller.writeByte(DomainClientProtocol.RETURN_APPLY_UPDATES_RESULT_COUNT);
            marshaller.writeInt(responses.size());
            for (HostUpdateResult<?> response : responses) {
                marshaller.writeByte(DomainClientProtocol.RETURN_APPLY_HOST_UPDATE);
                marshaller.writeObject(response);

View Full Code Here


        @Override
        protected void sendResponse(final OutputStream output) throws IOException {
            DomainUpdateApplierResponse response = processUpdate();
            final Marshaller marshaller = getMarshaller();
            marshaller.start(createByteOutput(output));
            marshaller.writeByte(DomainClientProtocol.RETURN_APPLY_UPDATE);
            marshaller.writeObject(response);
            marshaller.finish();
        }

View Full Code Here


        @Override
        protected void sendResponse(final OutputStream output) throws IOException {
            UpdateResultHandlerResponse<?> response = processUpdate();
            final Marshaller marshaller = getMarshaller();
            marshaller.start(createByteOutput(output));
            marshaller.writeByte(DomainClientProtocol.RETURN_APPLY_SERVER_MODEL_UPDATE);
            marshaller.writeObject(response);
            marshaller.finish();
        }

View Full Code Here

        }


        @Override
        protected void sendResponse(final OutputStream output) throws IOException {
            final Marshaller marshaller = getMarshaller();
            marshaller.start(createByteOutput(output));


            BlockingQueue<List<StreamedResponse>> responseQueue = new LinkedBlockingQueue<List<StreamedResponse>>();
            domainController.executeDeploymentPlan(deploymentPlan, responseQueue);
            StreamedResponse rsp;
            do {

View Full Code Here

        }


        @Override
        protected final void sendResponse(final OutputStream output) throws IOException {
            final Marshaller marshaller = getMarshaller();
            marshaller.start(createByteOutput(output));
            marshaller.writeByte(DomainControllerProtocol.PARAM_DOMAIN_MODEL);
            marshaller.writeObject(domainController.getDomainModel());
            marshaller.finish();
        }
    }

View Full Code Here

        }


        @Override
        protected void sendResponse(final OutputStream outputStream) throws IOException {
                final Marshaller marshaller = getMarshaller();
                marshaller.start(createByteOutput(outputStream));
                marshaller.writeByte(DomainClientProtocol.RETURN_DOMAIN_MODEL);
                marshaller.writeObject(domainController.getDomainModel());
                marshaller.finish();
        }
    }

View Full Code Here

        }


        @Override
        protected void sendResponse(final OutputStream outputStream) throws IOException {
                final Marshaller marshaller = getMarshaller();
                marshaller.start(createByteOutput(outputStream));
                Set<String> serverManagerNames = domainController.getServerManagerNames();
                marshaller.writeByte(DomainClientProtocol.RETURN_SERVER_MANAGER_COUNT);
                marshaller.writeInt(serverManagerNames.size());
                for (String name : serverManagerNames) {
                    marshaller.writeByte(DomainClientProtocol.RETURN_HOST_NAME);

View Full Code Here

        }


        @Override
        protected void sendResponse(final OutputStream outputStream) throws IOException {
                final Marshaller marshaller = getMarshaller();
                marshaller.start(createByteOutput(outputStream));
                marshaller.writeByte(DomainClientProtocol.RETURN_HOST_MODEL);
                marshaller.writeObject(domainController.getHostModel(serverManagerName));
                marshaller.finish();
        }
    }

View Full Code Here


        @Override
        protected void sendResponse(final OutputStream outputStream) throws IOException {
            Map<ServerIdentity, ServerStatus> statuses = domainController.getServerStatuses();
            final Marshaller marshaller = getMarshaller();
            marshaller.start(createByteOutput(outputStream));
            marshaller.writeByte(DomainClientProtocol.RETURN_SERVER_STATUS_COUNT);
            marshaller.writeInt(statuses.size());
            for (Map.Entry<ServerIdentity, ServerStatus> entry : statuses.entrySet()) {
                ServerIdentity id = entry.getKey();
                marshaller.writeByte(DomainClientProtocol.RETURN_HOST_NAME);

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

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.