001
014
015 package com.liferay.portal.kernel.process;
016
017 import com.liferay.portal.kernel.io.DummyOutputStream;
018 import com.liferay.portal.kernel.util.StreamUtil;
019
020 import java.io.IOException;
021 import java.io.InputStream;
022
023
026 public class ConsumerOutputProcessor implements OutputProcessor<Void, Void> {
027
028 @Override
029 public Void processStdErr(InputStream stdErrInputStream)
030 throws ProcessException {
031
032 _consume(stdErrInputStream);
033
034 return null;
035 }
036
037 @Override
038 public Void processStdOut(InputStream stdOutInputStream)
039 throws ProcessException {
040
041 _consume(stdOutInputStream);
042
043 return null;
044 }
045
046 private void _consume(InputStream inputStream) throws ProcessException {
047 try {
048 StreamUtil.transfer(inputStream, new DummyOutputStream());
049 }
050 catch (IOException ioe) {
051 throw new ProcessException(ioe);
052 }
053 }
054
055 }