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

  • Field Summary

    Fields inherited from class org.jboss.marshalling.AbstractUnmarshaller

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

    Fields inherited from class org.jboss.marshalling.SimpleDataInput

    buffer, limit, position, totalBytesRead

    Fields inherited from class org.jboss.marshalling.ByteInputStream

    byteInput

  • 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.

    Methods inherited from class org.jboss.marshalling.river.RiverUnmarshaller

    clearClassCache, clearInstanceCache, close, discardFields, doReadNewObject, doReadObject, readFields, readString, readUTF, start

    Methods inherited from class org.jboss.marshalling.AbstractUnmarshaller

    filterCheck, setObjectInputStreamFilter

    Methods inherited from class org.jboss.marshalling.AbstractObjectInput

    readObject, readObject, readObjectUnshared, readObjectUnshared

    Methods inherited from class org.jboss.marshalling.SimpleDataInput

    available, read, read, read, readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readInt, readIntDirect, readLine, readLong, readLongDirect, readShort, readUnsignedByte, readUnsignedByteDirect, readUnsignedShort, skip, skipBytes

    Methods inherited from class java.io.InputStream

    mark, markSupported, nullInputStream, readAllBytes, readNBytes, readNBytes, reset, transferTo

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.jboss.marshalling.ByteInput

    available, read, read, read, skip

    Methods inherited from interface java.io.DataInput

    readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readInt, readLine, readLong, readShort, readUnsignedByte, readUnsignedShort, skipBytes

    Methods inherited from interface java.io.ObjectInput

    available, read, read, read, readObject, skip

    Methods inherited from interface org.jboss.marshalling.Unmarshaller

    readObject, readObjectUnshared, readObjectUnshared

  • Constructor Details

    • ExtendedRiverUnmarshaller

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

  • Method Details

    • finish

      public void finish() throws IOException
      Specified by:
      finish in interface org.jboss.marshalling.Unmarshaller
      Overrides:
      finish in class org.jboss.marshalling.river.RiverUnmarshaller
      Throws:
      IOException

    • getUnreadBufferedCount

      public int getUnreadBufferedCount()
      Returns number unread buffered bytes.