001
014
015 package com.liferay.portal.kernel.process;
016
017 import java.io.IOException;
018 import java.io.InputStream;
019
020
023 public class ConsumerOutputProcessor implements OutputProcessor<Void, Void> {
024
025 @Override
026 public Void processStdErr(InputStream stdErrInputStream)
027 throws ProcessException {
028
029 _consume(stdErrInputStream);
030
031 return null;
032 }
033
034 @Override
035 public Void processStdOut(InputStream stdOutInputStream)
036 throws ProcessException {
037
038 _consume(stdOutInputStream);
039
040 return null;
041 }
042
043 private void _consume(InputStream inputStream) throws ProcessException {
044 byte[] buffer = new byte[1024];
045
046 try {
047 while (inputStream.read(buffer) != -1);
048 }
049 catch (IOException ioe) {
050 throw new ProcessException(ioe);
051 }
052 finally {
053 try {
054 inputStream.close();
055 }
056 catch (IOException ioe) {
057 throw new ProcessException(ioe);
058 }
059 }
060 }
061
062 }