nl.nn.adapterframework.util

Class StreamCaptureUtils

java.lang.Object

nl.nn.adapterframework.util.StreamCaptureUtils

public class StreamCaptureUtils
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_STREAM_CAPTURE_LIMIT
protected static org.apache.logging.log4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
StreamCaptureUtils()

Method Summary

Modifier and Type	Method and Description
static InputStream	captureInputStream(InputStream in, OutputStream capture)
static InputStream	captureInputStream(InputStream in, OutputStream capture, int maxSize, boolean captureRemainingOnClose)
static OutputStream	captureOutputStream(OutputStream stream, OutputStream capture)
static OutputStream	captureOutputStream(OutputStream stream, OutputStream capture, int maxSize)
static Reader	captureReader(Reader in, Writer capture)
static Reader	captureReader(Reader in, Writer capture, int maxSize, boolean captureRemainingOnClose)
static Writer	captureWriter(Writer writer, Writer capture)
static Writer	captureWriter(Writer writer, Writer capture, int maxSize)
static OutputStream	limitSize(OutputStream stream, int maxSize) Triggers the next byte after the threshold has been reached.
static Writer	limitSize(Writer writer, int maxSize)
static InputStream	watch(InputStream stream, Runnable onClose, Function<IOException,IOException> onException)
static InputStream	watch(InputStream stream, Runnable onClose, Runnable onException)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

protected static org.apache.logging.log4j.Logger log

DEFAULT_STREAM_CAPTURE_LIMIT

public static final int DEFAULT_STREAM_CAPTURE_LIMIT

See Also:

Constant Field Values

Constructor Detail

StreamCaptureUtils

public StreamCaptureUtils()

Method Detail

watch

public static InputStream watch(InputStream stream,
                                Runnable onClose,
                                Runnable onException)

watch

public static InputStream watch(InputStream stream,
                                Runnable onClose,
                                Function<IOException,IOException> onException)

limitSize

public static OutputStream limitSize(OutputStream stream,
                                     int maxSize)

Triggers the next byte after the threshold has been reached. If bytes are written in chunks it triggers after processing the entire chunk.

limitSize

public static Writer limitSize(Writer writer,
                               int maxSize)

captureInputStream

public static InputStream captureInputStream(InputStream in,
                                             OutputStream capture)

captureInputStream

public static InputStream captureInputStream(InputStream in,
                                             OutputStream capture,
                                             int maxSize,
                                             boolean captureRemainingOnClose)

captureOutputStream

public static OutputStream captureOutputStream(OutputStream stream,
                                               OutputStream capture)

captureOutputStream

public static OutputStream captureOutputStream(OutputStream stream,
                                               OutputStream capture,
                                               int maxSize)

captureReader

public static Reader captureReader(Reader in,
                                   Writer capture)

captureReader

public static Reader captureReader(Reader in,
                                   Writer capture,
                                   int maxSize,
                                   boolean captureRemainingOnClose)

captureWriter

public static Writer captureWriter(Writer writer,
                                   Writer capture)

captureWriter

public static Writer captureWriter(Writer writer,
                                   Writer capture,
                                   int maxSize)