Package org.jboss.marshalling

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


        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


            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);
            }
            marshaller.finish();
        }
    }
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();
        }

        private DomainUpdateApplierResponse processUpdate() {
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();
        }

        private UpdateResultHandlerResponse<?> processUpdate() {
View Full Code Here

                    Thread.currentThread().interrupt();
                    throw new IOException("Interrupted while reading deployment plan execution responses", ie);
                }
                for (StreamedResponse item : rspList) {
                    rsp = item;
                    marshaller.writeByte(rsp.getProtocolValue());
                    log.tracef("Marshalling StreamedResponse %s", rsp.getProtocolValue());
                    if (rsp.getValue() != null) {
                        marshaller.writeObject(rsp.getValue());
                    }
                }
View Full Code Here

            final Marshaller marshaller = getMarshaller();
            marshaller.start(createByteOutput(output));
            marshaller.writeByte(ServerManagerProtocol.PARAM_SERVER_NAME);
            marshaller.writeUTF(serverName);
            if (gracefulTimeout != null) {
                marshaller.writeByte(ServerManagerProtocol.PARAM_GRACEFUL_TIMEOUT);
                marshaller.writeLong(gracefulTimeout);
            }
            marshaller.finish();
        }
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);
                    marshaller.writeUTF(name);
                }
View Full Code Here

                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);
                    marshaller.writeUTF(name);
                }
                marshaller.finish();
        }
    }
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.