Package org.apache.commons.io.output

Examples of org.apache.commons.io.output.TeeOutputStream

225
226
227
228
229
230
231
232
233
234
235
                        if (local.length()>0){
                            output=new FileOutputStream(local);
                            if (target==null) {
                                target=output;
                            } else {
                                target = new TeeOutputStream(output,baos);
                            }
                        }
                        if (target == null){
                            target=new NullOutputStream();
                        }
View Full Code Here
159
160
161
162
163
164
165
166
167
168
169
170
    // capture sysout/ syserr.
    sw = new StringWriter();
    sysout = System.out;
    syserr = System.err;
    System.setOut(new PrintStream(new TeeOutputStream(System.out, new WriterOutputStream(sw))));
    System.setErr(new PrintStream(new TeeOutputStream(System.err, new WriterOutputStream(sw))));
   
    // Add custom logging handler because java logging keeps a reference to previous System.err.
    loggingMessages = new StringWriter();
    logger = Logger.getLogger("");
    handlers = logger.getHandlers();
View Full Code Here
152
153
154
155
156
157
158
159
160
161
162
                  if (local.length()>0){
                    output=new FileOutputStream(local);
                    if (target==null) {
                      target=output;
                    } else {
                      target = new TeeOutputStream(output,baos);
                    }
                  }
                  if (target == null){
                    target=new NullOutputStream();
                  }
View Full Code Here
223
224
225
226
227
228
229
230
231
232
233
            new BufferedOutputStream(
                new FileOutputStream(
                    new File(getHeritrixHome(), STARTLOG)),16384);
        PrintStream startupOut =
            new PrintStream(
                new TeeOutputStream(
                    System.out,
                    startupOutStream));

        CommandLine cl = getCommandLine(startupOut, args);
        if (cl == null) return;
View Full Code Here
494
495
496
497
498
499
500
501
502
  private static PumpStreamHandler redirectOutputAlsoTo(PumpStreamHandler pumps, OutputStream output) {
    if (output == null)
      throw new IllegalArgumentException("OutputStream must be provided.");
    OutputStream current = pumps.getOut();
    if (current != null && !(current instanceof NullOutputStream)) {
      output = new TeeOutputStream(current, output);
    }
    return new PumpStreamHandler(output, pumps.getErr(), pumps.getInput());
  }
View Full Code Here
509
510
511
512
513
514
515
516
517
  private static PumpStreamHandler redirectErrorAlsoTo(PumpStreamHandler pumps, OutputStream output) {
    if (output == null)
      throw new IllegalArgumentException("OutputStream must be provided.");
    OutputStream current = pumps.getErr();
    if (current != null && !(current instanceof NullOutputStream)) {
      output = new TeeOutputStream(current, output);
    }
    return new PumpStreamHandler(pumps.getOut(), output, pumps.getInput());
  }
View Full Code Here
48
49
50
51
52
53
54
55
56
57
58
    public void aroundWriteTo(ProceedingJoinPoint proceedingJoinPoint,
            MessageContext msgContext, OMOutputFormat format, OutputStream out, boolean preserve)
            throws Throwable {
        OutputStream log = LogManager.INSTANCE.createLog("formatter");
        try {
            OutputStream tee = new TeeOutputStream(out, log);
            proceedingJoinPoint.proceed(new Object[] { msgContext, format, tee, preserve });
        } finally {
            log.close();
        }
    }
View Full Code Here
189
190
191
192
193
194
195
196
197
198
199
          warnings = System.err;
          throw new RuntimeException("Communication not implemented: " + channel);
      }

      if (sinkLog != null) {
        sink = new TeeOutputStream(sink, new FileOutputStream(sinkLog));
      }

      serializer = new Serializer(new BufferedOutputStream(sink, bufferSize));

      // Redirect original streams and start running tests.
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
75
        if (execHandle != null) {
            throw new IllegalStateException("you have already called start() on this handle");
        }

        AbstractExecHandleBuilder execBuilder = execHandleFactory.create();
        execBuilder.setStandardOutput(new CloseShieldOutputStream(new TeeOutputStream(System.out, standardOutput)));
        execBuilder.setErrorOutput(new CloseShieldOutputStream(new TeeOutputStream(System.err, errorOutput)));
        execHandle = execBuilder.build();

        execHandle.start();

        return this;
View Full Code Here
82
83
84
85
86
87
88
89
90
91
92
        OutputStream out = serialOutput;
        if (compress) {
            out = new LZFOutputStream(serialOutput);
        }
        if (DEBUG) {
            out = new TeeOutputStream(out, System.out);
        }
        try {
            xstreamPersister.save(info, out);
            out.flush();
            out.close();
View Full Code Here
TOP

Related Classes of org.apache.commons.io.output.TeeOutputStream

  • ch.entwine.weblounge.cache.impl.CacheableHttpServletResponse
  • com.carrotsearch.ant.tasks.junit4.slave.SlaveMain
  • com.carrotsearch.randomizedtesting.WithNestedTestClass
  • com.niyamit.spreedly.LoggingInterceptor
  • hudson.model.UpdateSite
  • hudson.remoting.ChannelRunner$Fork
  • org.apache.axis2.transport.testkit.axis2.LogAspect
  • org.apache.jmeter.protocol.ftp.sampler.FTPSampler
  • org.archive.crawler.Heritrix
  • org.geoserver.importer.bdb.XStreamInfoSerialBinding
    • Copyright © 2018 www.massapicom. 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.