blasd.apex.core.io

Class ApexObjectStreamHelper

java.lang.Object

blasd.apex.core.io.ApexObjectStreamHelper

public class ApexObjectStreamHelper
extends Object

Various helpers related to Object stream

Author:

Benoit Lacelle

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOGGER

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ApexObjectStreamHelper()

Method Summary

Modifier and Type	Method and Description
static ObjectInput	wrapToHandleInputStream(ObjectInput objectInput)
static long	writeInputStream(ObjectOutput objectOutput, InputStream inputStream) Default chunk size is 1024
static long	writeInputStream(ObjectOutput objectOutput, InputStream inputStream, int chunkSize) Default chunk size is 1024

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

protected static final org.slf4j.Logger LOGGER

Constructor Detail

ApexObjectStreamHelper

protected ApexObjectStreamHelper()

Method Detail

writeInputStream

public static long writeInputStream(ObjectOutput objectOutput,
                                    InputStream inputStream)
                             throws IOException

Default chunk size is 1024

Parameters:

inputStream -

objectOutput -

Returns:

the number of transmitted bytes, as reading from the InputStream

Throws:

IOException

writeInputStream

public static long writeInputStream(ObjectOutput objectOutput,
                                    InputStream inputStream,
                                    int chunkSize)
                             throws IOException

Default chunk size is 1024

Parameters:

objectOutput - the ObjectOutput were the data from the inputStream are written. These bytes are send through a stream of ByteArrayMarker

inputStream - the inputStream from which bytes are read. We consume it until EOF is encountered, however it is not automatically closed

chunkSize - the size of the chunks in which the inputStream is fragmented

Returns:

the number of transmitted bytes, as reading from the InputStream. It does NOT include the overhead induced by the protocol (e.g. ByteArrayMarker own bytes)

Throws:

IOException

wrapToHandleInputStream

public static ObjectInput wrapToHandleInputStream(ObjectInput objectInput)

Parameters:

objectInput -

Returns:

an ObjectInput which may return InputStream on .readObject