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 public Void processStdErr(InputStream stdErrInputStream)
026 throws ProcessException {
027
028 _consume(stdErrInputStream);
029
030 return null;
031 }
032
033 public Void processStdOut(InputStream stdOutInputStream)
034 throws ProcessException {
035
036 _consume(stdOutInputStream);
037
038 return null;
039 }
040
041 private void _consume(InputStream inputStream) throws ProcessException {
042 byte[] buffer = new byte[1024];
043
044 try {
045 while (inputStream.read(buffer) != -1);
046 }
047 catch (IOException ioe) {
048 throw new ProcessException(ioe);
049 }
050 finally {
051 try {
052 inputStream.close();
053 }
054 catch (IOException ioe) {
055 throw new ProcessException(ioe);
056 }
057 }
058 }
059
060 }