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 com.google.gwt.uibinder.rebind.messages.MessageWriter

    if (messages.isMessage(elem)) {
      if (!elem.hasChildNodes()) {
        uiWriter.die("Empty message: " + elem);
      }


      MessageWriter message = messages.newMessage(elem);
      message.setDefaultMessage(elem.consumeInnerHtml(phiProvider.get(message)));
      return uiWriter.tokenForExpression(messages.declareMessage(message));
    }


    return null;
  }

View Full Code Here

Examples of com.pinterest.secor.writer.MessageWriter


    private void init() throws Exception {
        mOffsetTracker = new OffsetTracker();
        mMessageReader = new MessageReader(mConfig, mOffsetTracker);
        FileRegistry fileRegistry = new FileRegistry(mConfig);
        mMessageWriter = new MessageWriter(mConfig, mOffsetTracker, fileRegistry);
        mMessageParser = (MessageParser) ReflectionUtil.createMessageParser(
                mConfig.getMessageParserClass(), mConfig);
        mUploader = new Uploader(mConfig, mOffsetTracker, fileRegistry);
        mUnparsableMessages = 0.;
    }

View Full Code Here

Examples of com.wesabe.grendel.openpgp.MessageWriter

      random.nextBytes(original);
    }
    
    @Test
    public void itIsDecryptableByMessageReader() throws Exception {
      final MessageWriter writer = new MessageWriter(owner, ImmutableList.<KeySet>of(recipient), new SecureRandom());
      
      final byte[] encrypted = writer.write(original);
      
      final MessageReader reader = new MessageReader(owner, recipient);
      final byte[] decrypted = reader.read(encrypted);
      
      assertThat(decrypted).isEqualTo(original);

View Full Code Here

Examples of de.fhkn.in.uce.stun.message.MessageWriter

                if (message.isMethod(RelayingMethod.CONNECTION_ATTEMPT) && message.isIndication()) {
                    // Connect to the relay address to establish a
                    // data connection
                    Socket s = new Socket();
                    s.connect(relayServerEndpoint);
                    MessageWriter dataConnectionWriter = new MessageWriter(s.getOutputStream());
                    Message connectionBindRequestMessage = MessageStaticFactory.newSTUNMessageInstance(
                            STUNMessageClass.REQUEST, RelayingMethod.CONNECTION_BIND);
                    connectionBindRequestMessage.addAttribute(new Token(message.getAttribute(Token.class).getToken()));
                    dataConnectionWriter.writeMessage(connectionBindRequestMessage);
                    // TODO erfolgs oder fehlermeldung abwarten
                    socketQueue.add(s);
                } else if (message.isMethod(STUNMessageMethod.KEEP_ALIVE) && message.isSuccessResponse()) {
                    int lifetime = message.getAttribute(RelayingLifetime.class).getLifeTime();
                    logger.debug("Received lifetime response {}", lifetime);

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


        for (Iterator itr = inf.getElements(); itr.hasNext();) {
            QName name = (QName)itr.next();


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


            Type defaultType = getType(inf, name);
            Type 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();
            }
        }
        if (inf.isExtension()) {
            Type t = getSuperType();
            if (t != null) {

View Full Code Here

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

            }
        }
    }


    protected void writeElement(QName name, Object value, Type type, MessageWriter writer, Context context) {
        MessageWriter cwriter = getWriter(writer, name, type);


        type.writeObject(value, cwriter, context);


        cwriter.close();
    }

View Full Code Here

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


        cwriter.close();
    }


    private MessageWriter getWriter(MessageWriter writer, QName name, Type type) {
        MessageWriter cwriter;
        if (type.isAbstract()) {
            cwriter = writer.getElementWriter(name);
        } else {
            cwriter = writer.getElementWriter(name);
        }

View Full Code Here

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


    @Override
    public void writeObject(Object object, MessageWriter writer, Context context)
        throws DatabindingException {
        if (null == object) {
            MessageWriter nilWriter = writer.getAttributeWriter(XSI_NIL);


            nilWriter.writeValue("true");


            nilWriter.close();
        } else {
            AegisType type = determineType(context, object.getClass());


            if (null == type) {
                TypeMapping tm = context.getTypeMapping();

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

                            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.