Examples of MessageWriter

com.google.gwt.uibinder.rebind.messages.MessageWriter
com.pinterest.secor.writer.MessageWriter
Message writer appends Kafka messages to local log files. @author Pawel Garbacki (pawel@pinterest.com)
com.wesabe.grendel.openpgp.MessageWriter
cr.org/2005/033.pdf">An Attack on CFB Mode Encryption As Used By OpenPGP @see Implementation of Chosen-Ciphertext Attacks against PGP and GnuPG @see AsymmetricAlgorithm#ENCRYPTION_DEFAULT @see AsymmetricAlgorithm#SIGNING_DEFAULT @see SymmetricAlgorithm#DEFAULT @see HashAlgorithm#DEFAULT @see CompressionAlgorithm#DEFAULT
de.fhkn.in.uce.stun.message.MessageWriter
Helper class to write {@link Message} messages synchronized to an outputstream. @author Daniel Maier, Alexander Diener (aldiener@htwg-konstanz.de)
org.apache.cxf.aegis.xml.MessageWriter
Writes messages to an output stream. @author Dan Diephouse
org.apache.james.mime4j.dom.MessageWriter
An interface to write out content of {@link Message} and other DOM elements toan {@link OutputStream}.
org.codehaus.xfire.aegis.MessageWriter
Writes messages to an output stream. @author Dan Diephouse
org.eclipse.jetty.websocket.common.message.MessageWriter
Support for writing a single WebSocket TEXT message via a {@link Writer}
Note: Per WebSocket spec, all WebSocket TEXT messages must be encoded in UTF-8
org.eclipse.jgit.util.io.MessageWriter
Combines messages from an OutputStream (hopefully in UTF-8) and a Writer.
This class is primarily meant for {@link BaseConnection} in contexts where astandard error stream from a command execution, as well as messages from a side-band channel, need to be combined together into a buffer to represent the complete set of messages from a remote repository.
Writes made to the writer are re-encoded as UTF-8 and interleaved into the buffer that {@link #getRawStream()} also writes to.
{@link #toString()} returns all written data, after converting it to a Stringunder the assumption of UTF-8 encoding.
Internally {@link RawParseUtils#decode(byte[])} is used by {@code toString()}tries to work out a reasonably correct character set for the raw data.

Examples of org.apache.cxf.aegis.xml.MessageWriter

            if (optional) { // minOccurs = 0
                return;
            }
            if (aegisType.isNillable() && aegisType.isWriteOuter()) {
                ElementWriter writer = new ElementWriter(output);
                MessageWriter w2 = writer.getElementWriter(elementName);
                w2.writeXsiNil();
                w2.close();
                return;
            }
        }
        
        ElementWriter writer = new ElementWriter(output);
        MessageWriter w2 = writer.getElementWriter(elementName);
        if (getContext().isWriteXsiTypes()
            && aegisType != null 
            && aegisType.getSchemaType() != null) {
            // if we know the type, write it. We are standalone, and the reader needs it.
            w2.writeXsiType(aegisType.getSchemaType());
        }
        aegisType.writeObject(obj, w2, context);
        w2.close();
    }

View Full Code Here

Examples of org.apache.cxf.aegis.xml.MessageWriter


        testWrite(doc);
    }


    public void write(MessageWriter writer) {
        MessageWriter nons = writer.getElementWriter("nons");
        nons.writeValue("nons");
        nons.close();


        MessageWriter intval = writer.getElementWriter("int");
        intval.writeValueAsInt(new Integer(10000));
        intval.close();


        MessageWriter child1 = writer.getElementWriter("child1", "urn:child1");
        MessageWriter att1 = child1.getAttributeWriter("att1");
        att1.writeValue("att1");
        att1.close();
        MessageWriter att2 = child1.getAttributeWriter("att2", "");
        att2.writeValue("att2");
        att2.close();
        MessageWriter att3 = child1.getAttributeWriter("att3", "urn:att3");
        att3.writeValue("att3");
        att3.close();
        MessageWriter att4 = child1.getAttributeWriter("att4", null);
        att4.writeValue("att4");
        att4.close();


        child1.close();


        writer.close();
    }

View Full Code Here

Examples of org.apache.cxf.aegis.xml.MessageWriter

        // get AegisType based on the object instance
        assertNotNull("type is null", type);


        // write the ref
        SoapRefType soapRefType = new SoapRefType(type);
        MessageWriter cwriter = rootWriter.getElementWriter(soapRefType.getSchemaType());
        soapRefType.writeObject(instance, cwriter, context);
        cwriter.close();


        // write the trailing blocks (referenced objects)
        trailingBlocks.writeBlocks(rootWriter, context);


        // log xml for debugging

View Full Code Here

Examples of org.apache.cxf.aegis.xml.MessageWriter

    public void writeObject(Object object, MessageWriter writer,
                            Context context) throws DatabindingException {
        // add the content type attribute even if we are going to fall back.
        String contentType = getContentType(object, context);
        if (contentType != null && useXmimeBinaryType) {
            MessageWriter ctWriter = writer.getAttributeWriter(XML_MIME_CONTENT_TYPE);
            ctWriter.writeValue(contentType);
        }


        if (!context.isMtomEnabled()) {
            fallbackDelegate.writeObject(getBytes(object), writer, context);
            return;
        }
        
        Collection<Attachment> attachments = context.getAttachments();
        if (attachments == null) {
            attachments = new ArrayList<Attachment>();
            context.setAttachments(attachments);
        }


        String id = AttachmentUtil.createContentID(getSchemaType().getNamespaceURI());


        Attachment att = createAttachment(object, id);


        attachments.add(att);
        
        MessageWriter include = writer.getElementWriter(XOP_INCLUDE);
        MessageWriter href = include.getAttributeWriter(XOP_HREF);
        href.writeValue("cid:" + id);


        include.close();
    }

View Full Code Here

Examples of org.apache.cxf.aegis.xml.MessageWriter

            Context context,
            AegisType type) throws DatabindingException {


        type = TypeUtil.getWriteType(context.getGlobalContext(), value, type);


        MessageWriter cwriter = writer.getElementWriter(type.getSchemaType().getLocalPart(), "");


        if (value == null && type.isNillable()) {
            // null
            cwriter.writeXsiNil();
        } else if (type instanceof BeanType || type instanceof SoapArrayType) {
            // write refs to complex type
            String refId = MarshalRegistry.get(context).getInstanceId(value);
            SoapEncodingUtil.writeRef(cwriter, refId);
        } else {
            // write simple types inline
            type.writeObject(value, cwriter, context);
        }


        cwriter.close();
    }

View Full Code Here

Examples of org.apache.cxf.aegis.xml.MessageWriter


    protected void writeValue(Object value, MessageWriter writer, Context context,
                              AegisType type, String name,
                              String ns) throws DatabindingException {
        type = TypeUtil.getWriteType(context.getGlobalContext(), value, type);
        MessageWriter cwriter;
        if (!type.isFlatArray()) {
            cwriter = writer.getElementWriter(name, ns);
        } else {
            cwriter = writer;
        }


        if (value == null && type.isNillable()) {
            cwriter.writeXsiNil();
        } else {
            type.writeObject(value, cwriter, context);
        }


        if (!type.isFlatArray()) {
            cwriter.close();
        }
    }

View Full Code Here

Examples of org.apache.cxf.aegis.xml.MessageWriter

                if (type == null) {
                    throw new DatabindingException("Couldn't find type for " + value.getClass()
                                                   + " for property " + name);
                }


                MessageWriter cwriter = writer.getAttributeWriter(name);


                type.writeObject(value, cwriter, context);


                cwriter.close();
            }
        }


        if (inf.isExtension()) {
            AegisType t = getSuperType();
            if (t != null) {
                t.writeObject(object, writer, context);
            }
        }


        for (QName name : inf.getElements()) {


            if (inf.isExtension()
                && inf.getPropertyDescriptorFromMappedName(name).getReadMethod().getDeclaringClass() != inf
                    .getTypeClass()) {
                continue;
            }
            Object value = readProperty(object, name);


            AegisType defaultType = getType(inf, name);
            AegisType type = TypeUtil.getWriteType(context.getGlobalContext(), value, defaultType);


            // Write the value if it is not null.
            if (value != null) {
                if (type == null) {
                    throw new DatabindingException("Couldn't find type for " + value.getClass()
                                                   + " for property " + name);
                }


                writeElement(name, value, type, writer, context);
            } else if (inf.isNillable(name)) {
                MessageWriter cwriter = getWriter(writer, name, type);


                // Write the xsi:nil if it is null.
                cwriter.writeXsiNil();


                cwriter.close();
            }
        }
    }

View Full Code Here

Examples of org.apache.cxf.aegis.xml.MessageWriter


    protected void writeElement(QName name, Object value,
                                AegisType type, MessageWriter writer, Context context) {


        if (!type.isFlatArray()) {
            MessageWriter cwriter = null;
            cwriter = getWriter(writer, name, type);
            type.writeObject(value, cwriter, context);
            cwriter.close();
        } else {
            ArrayType arrayType = (ArrayType)type;
            arrayType.writeObject(value, writer, context, name);
        }
    }

View Full Code Here

Examples of org.apache.cxf.aegis.xml.MessageWriter

            arrayType.writeObject(value, writer, context, name);
        }
    }


    private MessageWriter getWriter(MessageWriter writer, QName name, AegisType type) {
        MessageWriter cwriter;
        cwriter = writer.getElementWriter(name);
        return cwriter;
    }

View Full Code Here

Examples of org.apache.cxf.aegis.xml.MessageWriter

                            AegisType kType, AegisType vType,
                            Map.Entry entry) throws DatabindingException {
        kType = TypeUtil.getWriteType(context.getGlobalContext(), entry.getKey(), kType);
        vType = TypeUtil.getWriteType(context.getGlobalContext(), entry.getValue(), vType);


        MessageWriter entryWriter = writer.getElementWriter(getEntryName());


        MessageWriter keyWriter = entryWriter.getElementWriter(getKeyName());
        kType.writeObject(entry.getKey(), keyWriter, context);
        keyWriter.close();
        if (entry.getValue() != null) {
            MessageWriter valueWriter = entryWriter.getElementWriter(getValueName());
            vType.writeObject(entry.getValue(), valueWriter, context);
            valueWriter.close();
        }


        entryWriter.close();
    }

View Full Code Here

0 1 2 3 4 5

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.