Class RiverMarshaller

java.lang.Object

java.io.OutputStream

org.jboss.marshalling.SimpleByteOutput

org.jboss.marshalling.ByteOutputStream

org.jboss.marshalling.SimpleDataOutput

org.jboss.marshalling.AbstractObjectOutput

org.jboss.marshalling.AbstractMarshaller

org.jboss.marshalling.river.RiverMarshaller

All Implemented Interfaces:

Closeable, DataOutput, Flushable, ObjectOutput, AutoCloseable, ByteOutput, Marshaller

public class RiverMarshaller
extends AbstractMarshaller

Field Summary

Fields

Modifier and Type	Field	Description
private static final IdentityIntMap<Class<?>>	BASIC_CLASSES_V2
private static final IdentityIntMap<Class<?>>	BASIC_CLASSES_V3
private BlockMarshaller	blockMarshaller
private final IdentityIntMap<Class<?>>	classCache
private int	classSeq
private final PrivilegedExceptionAction<RiverObjectOutputStream>	createObjectOutputStreamAction
private static final Field	ENUM_MAP_KEY_TYPE_FIELD
private static final Field	ENUM_SET_ELEMENT_TYPE_FIELD
private static final Field	ENUM_SET_VALUES_FIELD
private final IdentityHashMap<Class<?>, Externalizer>	externalizers
private final IdentityIntMap<Object>	instanceCache
private int	instanceSeq
private ObjectOutput	objectOutput
private RiverObjectOutputStream	objectOutputStream
private final SerializableClassRegistry	registry

Fields inherited from class AbstractMarshaller

classExternalizerFactory, classResolver, classTable, configuredVersion, exceptionListener, objectPreResolver, objectResolver, objectTable, serializabilityChecker, streamHeader

Fields inherited from class SimpleDataOutput

buffer, bufferSize

Fields inherited from class ByteOutputStream

byteOutput

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RiverMarshaller(RiverMarshallerFactory marshallerFactory, SerializableClassRegistry registry, MarshallingConfiguration configuration)

Method Summary

Modifier and Type	Method	Description
void	clearClassCache()	Discard the class cache.
void	clearInstanceCache()	Discard the instance cache.
private RiverObjectOutputStream	createObjectOutputStream()
protected void	doWriteEmptyFields(SerializableClass info)
protected void	doWriteFields(SerializableClass info, Object obj)
protected void	doWriteObject(Object original, boolean unshared)	Implementation of the actual object-writing method.
protected void	doWriteSerializableObject(SerializableClass info, Object obj, Class<?> objClass)
private static Class<? extends Enum>	getAccessibleEnumFieldValue(Field field, Object obj)
private static IdentityIntMap<Class<?>>	getBasicClasses(int configuredVersion)
protected BlockMarshaller	getBlockMarshaller()
private static Class<? extends Enum>	getEnumMapKeyType(Object obj)
private static Enum[]	getEnumSetElements(Object obj)
private static Class<? extends Enum>	getEnumSetElementType(Object obj)
protected ObjectOutput	getObjectOutput()
private RiverObjectOutputStream	getObjectOutputStream()
void	start(ByteOutput byteOutput)	Begin writing to a stream.
private void	writeBooleanArray(boolean[] booleans)
protected void	writeClass(Class<?> objClass)
protected void	writeClassClass(Class<?> classObj)
private void	writeClassTableData(Class<?> objClass, ClassTable.Writer classTableWriter)
private void	writeEndBlock()
protected void	writeEnumClass(Class<? extends Enum> objClass)
protected void	writeExternalizableClass(Class<?> objClass)
protected void	writeExternalizerClass(Class<?> objClass, Externalizer externalizer)
protected boolean	writeKnownClass(Class<?> objClass)
protected void	writeNewClass(Class<?> objClass)
protected void	writeNewEnumClass(Class<? extends Enum> objClass)
protected void	writeNewExternalizableClass(Class<?> objClass)
protected void	writeNewExternalizerClass(Class<?> objClass, Externalizer externalizer)
protected void	writeNewProxyClass(Class<?> objClass)
protected void	writeNewSerializableClass(Class<?> objClass)
protected void	writeObjectArrayClass(Class<?> objClass)
protected void	writeProxyClass(Class<?> objClass)
protected void	writeSerializableClass(Class<?> objClass)
private void	writeString(String string)
void	writeUTF(String string)

Methods inherited from class AbstractMarshaller

close, finish, writeObject, writeObjectUnshared

Methods inherited from class SimpleDataOutput

flush, shallowFlush, write, write, write, writeBoolean, writeByte, writeBytes, writeChar, writeChars, writeDouble, writeFloat, writeInt, writeLong, writeShort

Methods inherited from class OutputStream

nullOutputStream

Methods inherited from class Object

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

Methods inherited from interface ByteOutput

write, write, write

Methods inherited from interface DataOutput

writeBoolean, writeByte, writeBytes, writeChar, writeChars, writeDouble, writeFloat, writeInt, writeLong, writeShort

Methods inherited from interface Flushable

flush

Methods inherited from interface ObjectOutput

flush, write, write, write

Field Details

instanceCache

private final IdentityIntMap<Object> instanceCache

classCache

private final IdentityIntMap<Class<?>> classCache

externalizers

private final IdentityHashMap<Class<?>, Externalizer> externalizers

instanceSeq

private int instanceSeq

classSeq

private int classSeq

registry

private final SerializableClassRegistry registry

objectOutputStream

private RiverObjectOutputStream objectOutputStream

objectOutput

private ObjectOutput objectOutput

blockMarshaller

private BlockMarshaller blockMarshaller

createObjectOutputStreamAction

private final PrivilegedExceptionAction<RiverObjectOutputStream> createObjectOutputStreamAction

BASIC_CLASSES_V2

private static final IdentityIntMap<Class<?>> BASIC_CLASSES_V2

BASIC_CLASSES_V3

private static final IdentityIntMap<Class<?>> BASIC_CLASSES_V3

ENUM_SET_ELEMENT_TYPE_FIELD

private static final Field ENUM_SET_ELEMENT_TYPE_FIELD

ENUM_SET_VALUES_FIELD

private static final Field ENUM_SET_VALUES_FIELD

ENUM_MAP_KEY_TYPE_FIELD

private static final Field ENUM_MAP_KEY_TYPE_FIELD

Constructor Details

RiverMarshaller

protected RiverMarshaller(RiverMarshallerFactory marshallerFactory,
 SerializableClassRegistry registry,
 MarshallingConfiguration configuration)
                   throws IOException

Throws:

IOException

Method Details

doWriteObject

protected void doWriteObject(Object original,
 boolean unshared)
                      throws IOException

Description copied from class: AbstractObjectOutput

Implementation of the actual object-writing method.

Specified by:

doWriteObject in class AbstractObjectOutput

Parameters:

original - the object to write

unshared - true if the instance is unshared, false if it is shared

Throws:

IOException - if an I/O error occurs

getBasicClasses

private static IdentityIntMap<Class<?>> getBasicClasses(int configuredVersion)

getEnumMapKeyType

private static Class<? extends Enum> getEnumMapKeyType(Object obj)

getEnumSetElementType

private static Class<? extends Enum> getEnumSetElementType(Object obj)

getEnumSetElements

private static Enum[] getEnumSetElements(Object obj)

getAccessibleEnumFieldValue

private static Class<? extends Enum> getAccessibleEnumFieldValue(Field field,
 Object obj)

writeBooleanArray

private void writeBooleanArray(boolean[] booleans)
                        throws IOException

Throws:

IOException

writeEndBlock

private void writeEndBlock()
                    throws IOException

Throws:

IOException

getObjectOutput

protected ObjectOutput getObjectOutput()

getBlockMarshaller

protected BlockMarshaller getBlockMarshaller()

getObjectOutputStream

private RiverObjectOutputStream getObjectOutputStream()
                                               throws IOException

Throws:

IOException

createObjectOutputStream

private RiverObjectOutputStream createObjectOutputStream()
                                                  throws IOException

Throws:

IOException

doWriteSerializableObject

protected void doWriteSerializableObject(SerializableClass info,
 Object obj,
 Class<?> objClass)
                                  throws IOException

Throws:

IOException

doWriteFields

protected void doWriteFields(SerializableClass info,
 Object obj)
                      throws IOException

Throws:

IOException

doWriteEmptyFields

protected void doWriteEmptyFields(SerializableClass info)
                           throws IOException

Throws:

IOException

writeProxyClass

protected void writeProxyClass(Class<?> objClass)
                        throws IOException

Throws:

IOException

writeNewProxyClass

protected void writeNewProxyClass(Class<?> objClass)
                           throws IOException

Throws:

IOException

writeEnumClass

protected void writeEnumClass(Class<? extends Enum> objClass)
                       throws IOException

Throws:

IOException

writeNewEnumClass

protected void writeNewEnumClass(Class<? extends Enum> objClass)
                          throws IOException

Throws:

IOException

writeClassClass

protected void writeClassClass(Class<?> classObj)
                        throws IOException

Throws:

IOException

writeObjectArrayClass

protected void writeObjectArrayClass(Class<?> objClass)
                              throws IOException

Throws:

IOException

writeClass

protected void writeClass(Class<?> objClass)
                   throws IOException

Throws:

IOException

writeNewClass

protected void writeNewClass(Class<?> objClass)
                      throws IOException

Throws:

IOException

writeClassTableData

private void writeClassTableData(Class<?> objClass,
 ClassTable.Writer classTableWriter)
                          throws IOException

Throws:

IOException

writeKnownClass

protected boolean writeKnownClass(Class<?> objClass)
                           throws IOException

Throws:

IOException

writeSerializableClass

protected void writeSerializableClass(Class<?> objClass)
                               throws IOException

Throws:

IOException

writeNewSerializableClass

protected void writeNewSerializableClass(Class<?> objClass)
                                  throws IOException

Throws:

IOException

writeExternalizableClass

protected void writeExternalizableClass(Class<?> objClass)
                                 throws IOException

Throws:

IOException

writeNewExternalizableClass

protected void writeNewExternalizableClass(Class<?> objClass)
                                    throws IOException

Throws:

IOException

writeExternalizerClass

protected void writeExternalizerClass(Class<?> objClass,
 Externalizer externalizer)
                               throws IOException

Throws:

IOException

writeNewExternalizerClass

protected void writeNewExternalizerClass(Class<?> objClass,
 Externalizer externalizer)
                                  throws IOException

Throws:

IOException

clearInstanceCache

public void clearInstanceCache()
                        throws IOException

Description copied from interface: Marshaller

Discard the instance cache. May also discard the class cache in implementations that do not support separated class and instance caches.

Throws:

IOException - if an error occurs

clearClassCache

public void clearClassCache()
                     throws IOException

Description copied from interface: Marshaller

Discard the class cache. Implicitly also discards the instance cache.

Throws:

IOException - if an error occurs

start

public void start(ByteOutput byteOutput)
           throws IOException

Description copied from class: AbstractMarshaller

Begin writing to a stream.

Specified by:

start in interface Marshaller

Overrides:

start in class AbstractMarshaller

Parameters:

byteOutput - the new stream

Throws:

IOException - if an error occurs

writeString

private void writeString(String string)
                  throws IOException

Throws:

IOException

writeUTF

public void writeUTF(String string)
              throws IOException

Description copied from class: SimpleDataOutput

Specified by:

writeUTF in interface DataOutput

Overrides:

writeUTF in class SimpleDataOutput

Throws:

IOException