Package org.frankframework.util

Class StreamCaptureUtils

java.lang.Object

org.frankframework.util.StreamCaptureUtils

public class StreamCaptureUtils
extends Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
StreamCaptureUtils()

Method Summary

Modifier and Type	Method	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, Runnable onException)
static InputStream	watch(InputStream stream, Runnable onClose, Function<IOException,IOException> onException)

Methods inherited from class java.lang.Object

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

Field Details

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 Details

StreamCaptureUtils

public StreamCaptureUtils()

Method Details

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)