Package org.infinispan.jboss.marshalling.commons

Class ExtendedRiverUnmarshaller

java.lang.Object

java.io.InputStream

org.jboss.marshalling.SimpleByteInput

org.jboss.marshalling.ByteInputStream

org.jboss.marshalling.SimpleDataInput

org.jboss.marshalling.AbstractObjectInput

org.jboss.marshalling.AbstractUnmarshaller

org.jboss.marshalling.river.RiverUnmarshaller

org.infinispan.jboss.marshalling.commons.ExtendedRiverUnmarshaller

All Implemented Interfaces:

Closeable, DataInput, ObjectInput, AutoCloseable, org.jboss.marshalling.ByteInput, org.jboss.marshalling.Unmarshaller

public class ExtendedRiverUnmarshaller
extends org.jboss.marshalling.river.RiverUnmarshaller

An extended RiverUnmarshaller that allows to track lifecycle of unmarshaller so that pools can be notified when not in use any more.

Since:

5.1

Author:

Galder Zamarreño

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ExtendedRiverUnmarshaller(org.jboss.marshalling.river.RiverMarshallerFactory factory, org.jboss.marshalling.reflect.SerializableClassRegistry registry, org.jboss.marshalling.MarshallingConfiguration cfg)

Method Summary

Modifier and Type	Method	Description
void	finish()
int	getUnreadBufferedCount()	Returns number unread buffered bytes.

Constructor Detail

ExtendedRiverUnmarshaller

protected ExtendedRiverUnmarshaller(org.jboss.marshalling.river.RiverMarshallerFactory factory,
                                    org.jboss.marshalling.reflect.SerializableClassRegistry registry,
                                    org.jboss.marshalling.MarshallingConfiguration cfg)

Method Detail

finish

public void finish()
            throws IOException

Throws:

IOException

getUnreadBufferedCount

public int getUnreadBufferedCount()

Returns number unread buffered bytes.