源码类别
热门源码
 当前位置：源码 > Java源码 >

Java源码示例：com.sun.xml.internal.ws.util.ByteArrayBuffer

示例1
private Packet decodePacket(@NotNull WSHTTPConnection con, @NotNull Codec codec) throws IOException {
    String ct = con.getRequestHeader("Content-Type");
    InputStream in = con.getInput();
    Packet packet = new Packet();
    packet.soapAction = fixQuotesAroundSoapAction(con.getRequestHeader("SOAPAction"));
    packet.wasTransportSecure = con.isSecure();
    packet.acceptableMimeTypes = con.getRequestHeader("Accept");
    packet.addSatellite(con);
    addSatellites(packet);
    packet.isAdapterDeliversNonAnonymousResponse = true;
    packet.component = this;
    packet.transportBackChannel = new Oneway(con);
    packet.webServiceContextDelegate = con.getWebServiceContextDelegate();
    packet.setState(Packet.State.ServerRequest);
    if (dump || LOGGER.isLoggable(Level.FINER)) {
        ByteArrayBuffer buf = new ByteArrayBuffer();
        buf.write(in);
        in.close();
        dump(buf, "HTTP request", con.getRequestHeaders());
        in = buf.newInputStream();
    }
    codec.decode(in, ct, packet);
    return packet;
}
示例2
@Override
public byte[] asByteArray() {
    if (buf == null) {
        ByteArrayBuffer baf = new ByteArrayBuffer();
        try {
            baf.write(part.readOnce());
        } catch(IOException ioe) {
            throw new WebServiceException(ioe);
        } finally {
            if (baf != null) {
                try {
                    baf.close();
                } catch (IOException ex) {
                    Logger.getLogger(MimeMultipartParser.class.getName()).log(Level.FINE, null, ex);
                }
            }
        }
        buf = baf.toByteArray();
    }
    return buf;
}
示例3
private Document createDOM(SDDocument doc) {
    // Get infoset
    ByteArrayBuffer bab = new ByteArrayBuffer();
    try {
        doc.writeTo(null, resolver, bab);
    } catch (IOException ioe) {
        throw new WebServiceException(ioe);
    }

    // Convert infoset to DOM
    Transformer trans = XmlUtil.newTransformer();
    Source source = new StreamSource(bab.newInputStream(), null); //doc.getURL().toExternalForm());
    DOMResult result = new DOMResult();
    try {
        trans.transform(source, result);
    } catch(TransformerException te) {
        throw new WebServiceException(te);
    }
    return (Document)result.getNode();
}
示例4
private Packet decodePacket(@NotNull WSHTTPConnection con, @NotNull Codec codec) throws IOException {
    String ct = con.getRequestHeader("Content-Type");
    InputStream in = con.getInput();
    Packet packet = new Packet();
    packet.soapAction = fixQuotesAroundSoapAction(con.getRequestHeader("SOAPAction"));
    packet.wasTransportSecure = con.isSecure();
    packet.acceptableMimeTypes = con.getRequestHeader("Accept");
    packet.addSatellite(con);
    addSatellites(packet);
    packet.isAdapterDeliversNonAnonymousResponse = true;
    packet.component = this;
    packet.transportBackChannel = new Oneway(con);
    packet.webServiceContextDelegate = con.getWebServiceContextDelegate();
    packet.setState(Packet.State.ServerRequest);
    if (dump || LOGGER.isLoggable(Level.FINER)) {
        ByteArrayBuffer buf = new ByteArrayBuffer();
        buf.write(in);
        in.close();
        dump(buf, "HTTP request", con.getRequestHeaders());
        in = buf.newInputStream();
    }
    codec.decode(in, ct, packet);
    return packet;
}
示例5
@Override
public byte[] asByteArray() {
    if (buf == null) {
        ByteArrayBuffer baf = new ByteArrayBuffer();
        try {
            baf.write(part.readOnce());
        } catch(IOException ioe) {
            throw new WebServiceException(ioe);
        } finally {
            if (baf != null) {
                try {
                    baf.close();
                } catch (IOException ex) {
                    Logger.getLogger(MimeMultipartParser.class.getName()).log(Level.FINE, null, ex);
                }
            }
        }
        buf = baf.toByteArray();
    }
    return buf;
}
示例6
private Document createDOM(SDDocument doc) {
    // Get infoset
    ByteArrayBuffer bab = new ByteArrayBuffer();
    try {
        doc.writeTo(null, resolver, bab);
    } catch (IOException ioe) {
        throw new WebServiceException(ioe);
    }

    // Convert infoset to DOM
    Transformer trans = XmlUtil.newTransformer();
    Source source = new StreamSource(bab.newInputStream(), null); //doc.getURL().toExternalForm());
    DOMResult result = new DOMResult();
    try {
        trans.transform(source, result);
    } catch(TransformerException te) {
        throw new WebServiceException(te);
    }
    return (Document)result.getNode();
}
示例7
private Packet decodePacket(@NotNull WSHTTPConnection con, @NotNull Codec codec) throws IOException {
    String ct = con.getRequestHeader("Content-Type");
    InputStream in = con.getInput();
    Packet packet = new Packet();
    packet.soapAction = fixQuotesAroundSoapAction(con.getRequestHeader("SOAPAction"));
    packet.wasTransportSecure = con.isSecure();
    packet.acceptableMimeTypes = con.getRequestHeader("Accept");
    packet.addSatellite(con);
    addSatellites(packet);
    packet.isAdapterDeliversNonAnonymousResponse = true;
    packet.component = this;
    packet.transportBackChannel = new Oneway(con);
    packet.webServiceContextDelegate = con.getWebServiceContextDelegate();
    packet.setState(Packet.State.ServerRequest);
    if (dump || LOGGER.isLoggable(Level.FINER)) {
        ByteArrayBuffer buf = new ByteArrayBuffer();
        buf.write(in);
        in.close();
        dump(buf, "HTTP request", con.getRequestHeaders());
        in = buf.newInputStream();
    }
    codec.decode(in, ct, packet);
    return packet;
}
示例8
@Override
public byte[] asByteArray() {
    if (buf == null) {
        ByteArrayBuffer baf = new ByteArrayBuffer();
        try {
            baf.write(part.readOnce());
        } catch(IOException ioe) {
            throw new WebServiceException(ioe);
        } finally {
            if (baf != null) {
                try {
                    baf.close();
                } catch (IOException ex) {
                    Logger.getLogger(MimeMultipartParser.class.getName()).log(Level.FINE, null, ex);
                }
            }
        }
        buf = baf.toByteArray();
    }
    return buf;
}
示例9
private Document createDOM(SDDocument doc) {
    // Get infoset
    ByteArrayBuffer bab = new ByteArrayBuffer();
    try {
        doc.writeTo(null, resolver, bab);
    } catch (IOException ioe) {
        throw new WebServiceException(ioe);
    }

    // Convert infoset to DOM
    Transformer trans = XmlUtil.newTransformer();
    Source source = new StreamSource(bab.newInputStream(), null); //doc.getURL().toExternalForm());
    DOMResult result = new DOMResult();
    try {
        trans.transform(source, result);
    } catch(TransformerException te) {
        throw new WebServiceException(te);
    }
    return (Document)result.getNode();
}
示例10
private Packet decodePacket(@NotNull WSHTTPConnection con, @NotNull Codec codec) throws IOException {
    String ct = con.getRequestHeader("Content-Type");
    InputStream in = con.getInput();
    Packet packet = new Packet();
    packet.soapAction = fixQuotesAroundSoapAction(con.getRequestHeader("SOAPAction"));
    packet.wasTransportSecure = con.isSecure();
    packet.acceptableMimeTypes = con.getRequestHeader("Accept");
    packet.addSatellite(con);
    addSatellites(packet);
    packet.isAdapterDeliversNonAnonymousResponse = true;
    packet.component = this;
    packet.transportBackChannel = new Oneway(con);
    packet.webServiceContextDelegate = con.getWebServiceContextDelegate();
    packet.setState(Packet.State.ServerRequest);
    if (dump || LOGGER.isLoggable(Level.FINER)) {
        ByteArrayBuffer buf = new ByteArrayBuffer();
        buf.write(in);
        in.close();
        dump(buf, "HTTP request", con.getRequestHeaders());
        in = buf.newInputStream();
    }
    codec.decode(in, ct, packet);
    return packet;
}
示例11
@Override
public byte[] asByteArray() {
    if (buf == null) {
        ByteArrayBuffer baf = new ByteArrayBuffer();
        try {
            baf.write(part.readOnce());
        } catch(IOException ioe) {
            throw new WebServiceException(ioe);
        } finally {
            if (baf != null) {
                try {
                    baf.close();
                } catch (IOException ex) {
                    Logger.getLogger(MimeMultipartParser.class.getName()).log(Level.FINE, null, ex);
                }
            }
        }
        buf = baf.toByteArray();
    }
    return buf;
}
示例12
private Document createDOM(SDDocument doc) {
    // Get infoset
    ByteArrayBuffer bab = new ByteArrayBuffer();
    try {
        doc.writeTo(null, resolver, bab);
    } catch (IOException ioe) {
        throw new WebServiceException(ioe);
    }

    // Convert infoset to DOM
    Transformer trans = XmlUtil.newTransformer();
    Source source = new StreamSource(bab.newInputStream(), null); //doc.getURL().toExternalForm());
    DOMResult result = new DOMResult();
    try {
        trans.transform(source, result);
    } catch(TransformerException te) {
        throw new WebServiceException(te);
    }
    return (Document)result.getNode();
}
示例13
private Packet decodePacket(@NotNull WSHTTPConnection con, @NotNull Codec codec) throws IOException {
    String ct = con.getRequestHeader("Content-Type");
    InputStream in = con.getInput();
    Packet packet = new Packet();
    packet.soapAction = fixQuotesAroundSoapAction(con.getRequestHeader("SOAPAction"));
    packet.wasTransportSecure = con.isSecure();
    packet.acceptableMimeTypes = con.getRequestHeader("Accept");
    packet.addSatellite(con);
    addSatellites(packet);
    packet.isAdapterDeliversNonAnonymousResponse = true;
    packet.component = this;
    packet.transportBackChannel = new Oneway(con);
    packet.webServiceContextDelegate = con.getWebServiceContextDelegate();
    packet.setState(Packet.State.ServerRequest);
    if (dump || LOGGER.isLoggable(Level.FINER)) {
        ByteArrayBuffer buf = new ByteArrayBuffer();
        buf.write(in);
        in.close();
        dump(buf, "HTTP request", con.getRequestHeaders());
        in = buf.newInputStream();
    }
    codec.decode(in, ct, packet);
    return packet;
}
示例14
@Override
public byte[] asByteArray() {
    if (buf == null) {
        ByteArrayBuffer baf = new ByteArrayBuffer();
        try {
            baf.write(part.readOnce());
        } catch(IOException ioe) {
            throw new WebServiceException(ioe);
        } finally {
            if (baf != null) {
                try {
                    baf.close();
                } catch (IOException ex) {
                    Logger.getLogger(MimeMultipartParser.class.getName()).log(Level.FINE, null, ex);
                }
            }
        }
        buf = baf.toByteArray();
    }
    return buf;
}
示例15
private Document createDOM(SDDocument doc) {
    // Get infoset
    ByteArrayBuffer bab = new ByteArrayBuffer();
    try {
        doc.writeTo(null, resolver, bab);
    } catch (IOException ioe) {
        throw new WebServiceException(ioe);
    }

    // Convert infoset to DOM
    Transformer trans = XmlUtil.newTransformer();
    Source source = new StreamSource(bab.newInputStream(), null); //doc.getURL().toExternalForm());
    DOMResult result = new DOMResult();
    try {
        trans.transform(source, result);
    } catch(TransformerException te) {
        throw new WebServiceException(te);
    }
    return (Document)result.getNode();
}
示例16
private Packet decodePacket(@NotNull WSHTTPConnection con, @NotNull Codec codec) throws IOException {
    String ct = con.getRequestHeader("Content-Type");
    InputStream in = con.getInput();
    Packet packet = new Packet();
    packet.soapAction = fixQuotesAroundSoapAction(con.getRequestHeader("SOAPAction"));
    packet.wasTransportSecure = con.isSecure();
    packet.acceptableMimeTypes = con.getRequestHeader("Accept");
    packet.addSatellite(con);
    addSatellites(packet);
    packet.isAdapterDeliversNonAnonymousResponse = true;
    packet.component = this;
    packet.transportBackChannel = new Oneway(con);
    packet.webServiceContextDelegate = con.getWebServiceContextDelegate();
    packet.setState(Packet.State.ServerRequest);
    if (dump || LOGGER.isLoggable(Level.FINER)) {
        ByteArrayBuffer buf = new ByteArrayBuffer();
        buf.write(in);
        in.close();
        dump(buf, "HTTP request", con.getRequestHeaders());
        in = buf.newInputStream();
    }
    codec.decode(in, ct, packet);
    return packet;
}
示例17
@Override
public byte[] asByteArray() {
    if (buf == null) {
        ByteArrayBuffer baf = new ByteArrayBuffer();
        try {
            baf.write(part.readOnce());
        } catch(IOException ioe) {
            throw new WebServiceException(ioe);
        } finally {
            if (baf != null) {
                try {
                    baf.close();
                } catch (IOException ex) {
                    Logger.getLogger(MimeMultipartParser.class.getName()).log(Level.FINE, null, ex);
                }
            }
        }
        buf = baf.toByteArray();
    }
    return buf;
}
示例18
private Document createDOM(SDDocument doc) {
    // Get infoset
    ByteArrayBuffer bab = new ByteArrayBuffer();
    try {
        doc.writeTo(null, resolver, bab);
    } catch (IOException ioe) {
        throw new WebServiceException(ioe);
    }

    // Convert infoset to DOM
    Transformer trans = XmlUtil.newTransformer();
    Source source = new StreamSource(bab.newInputStream(), null); //doc.getURL().toExternalForm());
    DOMResult result = new DOMResult();
    try {
        trans.transform(source, result);
    } catch(TransformerException te) {
        throw new WebServiceException(te);
    }
    return (Document)result.getNode();
}
示例19
private Packet decodePacket(@NotNull WSHTTPConnection con, @NotNull Codec codec) throws IOException {
    String ct = con.getRequestHeader("Content-Type");
    InputStream in = con.getInput();
    Packet packet = new Packet();
    packet.soapAction = fixQuotesAroundSoapAction(con.getRequestHeader("SOAPAction"));
    packet.wasTransportSecure = con.isSecure();
    packet.acceptableMimeTypes = con.getRequestHeader("Accept");
    packet.addSatellite(con);
    addSatellites(packet);
    packet.isAdapterDeliversNonAnonymousResponse = true;
    packet.component = this;
    packet.transportBackChannel = new Oneway(con);
    packet.webServiceContextDelegate = con.getWebServiceContextDelegate();
    packet.setState(Packet.State.ServerRequest);
    if (dump || LOGGER.isLoggable(Level.FINER)) {
        ByteArrayBuffer buf = new ByteArrayBuffer();
        buf.write(in);
        in.close();
        dump(buf, "HTTP request", con.getRequestHeaders());
        in = buf.newInputStream();
    }
    codec.decode(in, ct, packet);
    return packet;
}
示例20
@Override
public byte[] asByteArray() {
    if (buf == null) {
        ByteArrayBuffer baf = new ByteArrayBuffer();
        try {
            baf.write(part.readOnce());
        } catch(IOException ioe) {
            throw new WebServiceException(ioe);
        } finally {
            if (baf != null) {
                try {
                    baf.close();
                } catch (IOException ex) {
                    Logger.getLogger(MimeMultipartParser.class.getName()).log(Level.FINE, null, ex);
                }
            }
        }
        buf = baf.toByteArray();
    }
    return buf;
}
示例21
private Document createDOM(SDDocument doc) {
    // Get infoset
    ByteArrayBuffer bab = new ByteArrayBuffer();
    try {
        doc.writeTo(null, resolver, bab);
    } catch (IOException ioe) {
        throw new WebServiceException(ioe);
    }

    // Convert infoset to DOM
    Transformer trans = XmlUtil.newTransformer();
    Source source = new StreamSource(bab.newInputStream(), null); //doc.getURL().toExternalForm());
    DOMResult result = new DOMResult();
    try {
        trans.transform(source, result);
    } catch(TransformerException te) {
        throw new WebServiceException(te);
    }
    return (Document)result.getNode();
}
示例22
private Packet decodePacket(@NotNull WSHTTPConnection con, @NotNull Codec codec) throws IOException {
    String ct = con.getRequestHeader("Content-Type");
    InputStream in = con.getInput();
    Packet packet = new Packet();
    packet.soapAction = fixQuotesAroundSoapAction(con.getRequestHeader("SOAPAction"));
    packet.wasTransportSecure = con.isSecure();
    packet.acceptableMimeTypes = con.getRequestHeader("Accept");
    packet.addSatellite(con);
    addSatellites(packet);
    packet.isAdapterDeliversNonAnonymousResponse = true;
    packet.component = this;
    packet.transportBackChannel = new Oneway(con);
    packet.webServiceContextDelegate = con.getWebServiceContextDelegate();
    packet.setState(Packet.State.ServerRequest);
    if (dump || LOGGER.isLoggable(Level.FINER)) {
        ByteArrayBuffer buf = new ByteArrayBuffer();
        buf.write(in);
        in.close();
        dump(buf, "HTTP request", con.getRequestHeaders());
        in = buf.newInputStream();
    }
    codec.decode(in, ct, packet);
    return packet;
}
示例23
@Override
public byte[] asByteArray() {
    if (buf == null) {
        ByteArrayBuffer baf = new ByteArrayBuffer();
        try {
            baf.write(part.readOnce());
        } catch(IOException ioe) {
            throw new WebServiceException(ioe);
        } finally {
            if (baf != null) {
                try {
                    baf.close();
                } catch (IOException ex) {
                    Logger.getLogger(MimeMultipartParser.class.getName()).log(Level.FINE, null, ex);
                }
            }
        }
        buf = baf.toByteArray();
    }
    return buf;
}
示例24
private Document createDOM(SDDocument doc) {
    // Get infoset
    ByteArrayBuffer bab = new ByteArrayBuffer();
    try {
        doc.writeTo(null, resolver, bab);
    } catch (IOException ioe) {
        throw new WebServiceException(ioe);
    }

    // Convert infoset to DOM
    Transformer trans = XmlUtil.newTransformer();
    Source source = new StreamSource(bab.newInputStream(), null); //doc.getURL().toExternalForm());
    DOMResult result = new DOMResult();
    try {
        trans.transform(source, result);
    } catch(TransformerException te) {
        throw new WebServiceException(te);
    }
    return (Document)result.getNode();
}
示例25
public StreamAttachment(ByteArrayBuffer buffer, String contentId, String contentType) {
    this.contentId = contentId;
    this.contentType = contentType;
    this.byteArrayBuffer = buffer;
    this.data = byteArrayBuffer.getRawData();
    this.len = byteArrayBuffer.size();
}
示例26
@Override
public byte[] asByteArray() {
    ByteArrayBuffer bab = new ByteArrayBuffer();
    try {
        writeTo(bab);
    } catch (IOException e) {
        throw new WebServiceException(e);
    }
    return bab.getRawData();
}
示例27
@Override
public InputStream asInputStream() {
    ByteArrayBuffer bab = new ByteArrayBuffer();
    try {
        writeTo(bab);
    } catch (IOException e) {
        throw new WebServiceException(e);
    }
    return bab.newInputStream();
}
示例28
private static void dump(ByteArrayBuffer buf, String caption, Map<String, List<String>> headers) throws IOException {
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    PrintWriter pw = new PrintWriter(baos, true);
    pw.println("---["+caption +"]---");
    if (headers != null) {
        for (Entry<String, List<String>> header : headers.entrySet()) {
            if (header.getValue().isEmpty()) {
                // I don't think this is legal, but let's just dump it,
                // as the point of the dump is to uncover problems.
                pw.println(header.getValue());
            } else {
                for (String value : header.getValue()) {
                    pw.println(header.getKey() + ": " + value);
                }
            }
        }
    }
    if (buf.size() > dump_threshold) {
        byte[] b = buf.getRawData();
        baos.write(b, 0, dump_threshold);
        pw.println();
        pw.println(WsservletMessages.MESSAGE_TOO_LONG(HttpAdapter.class.getName() + ".dumpTreshold"));
    } else {
        buf.writeTo(baos);
    }
    pw.println("--------------------");

    String msg = baos.toString();
    if (dump) {
      System.out.println(msg);
    }
    if (LOGGER.isLoggable(Level.FINER)) {
      LOGGER.log(Level.FINER, msg);
    }
}
示例29
private void dump(ByteArrayBuffer buf, String caption, Map<String, List<String>> headers) throws IOException {
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    PrintWriter pw = new PrintWriter(baos, true);
    pw.println("---["+caption +"]---");
    for (Entry<String,List<String>> header : headers.entrySet()) {
        if(header.getValue().isEmpty()) {
            // I don't think this is legal, but let's just dump it,
            // as the point of the dump is to uncover problems.
            pw.println(header.getValue());
        } else {
            for (String value : header.getValue()) {
                pw.println(header.getKey()+": "+value);
            }
        }
    }

    if (buf.size() > HttpAdapter.dump_threshold) {
        byte[] b = buf.getRawData();
        baos.write(b, 0, HttpAdapter.dump_threshold);
        pw.println();
        pw.println(WsservletMessages.MESSAGE_TOO_LONG(HttpAdapter.class.getName() + ".dumpTreshold"));
    } else {
        buf.writeTo(baos);
    }
    pw.println("--------------------");

    String msg = baos.toString();
    if (dump) {
        System.out.println(msg);
    }
    if (LOGGER.isLoggable(Level.FINER)) {
        LOGGER.log(Level.FINER, msg);
    }
}
示例30
public static InputStream getUTF8Stream(String s) {
    try {
        ByteArrayBuffer bab = new ByteArrayBuffer();
        Writer w = new OutputStreamWriter(bab, "utf-8");
        w.write(s);
        w.close();
        return bab.newInputStream();
    } catch (IOException e) {
        throw new RuntimeException("should not happen");
    }
}