de.grogra.persistence
Class XAQueue.Reader

java.lang.Object
  extended by java.io.InputStream
      extended by de.grogra.util.HierarchicalQueue.Reader
          extended by de.grogra.persistence.XAQueue.Reader
All Implemented Interfaces:
PersistenceInput, java.io.Closeable, java.io.DataInput, java.io.ObjectInput
Direct Known Subclasses:
ModificationQueue.Applier, Transaction.Reader
Enclosing class:
XAQueue

public class XAQueue.Reader
extends HierarchicalQueue.Reader
implements PersistenceInput


Field Summary
 
Fields inherited from class de.grogra.util.HierarchicalQueue.Reader
in
 
Fields inherited from interface de.grogra.persistence.PersistenceInput
ARRAY_OBJECT, MANAGEABLE_OBJECT, MIN_UNUSED_KIND, NULL_OBJECT, PERSISTENT_OBJECT_ID, PLAIN_OBJECT, SERIALIZED_OBJECT, SHARED_OBJECT_REFERENCE, STRING_OBJECT
 
Constructor Summary
protected XAQueue.Reader()
           
 
Method Summary
 boolean areFieldsProvided()
           
 int beginArray()
           
 boolean beginComponent(ManageableType.ArrayComponent c, int index)
           
 ManageableType.Field beginField(ManageableType type, ManageableType.Field field)
           
 ManageableType beginManaged()
           
 void close()
           
 void endArray()
           
 void endComponent()
           
 void endField()
           
 void endManaged()
           
 PersistenceBindings getBindings()
           
 int getNextObjectKind()
           
 XAQueue getQueue()
           
 void open()
           
 java.lang.String readName()
           
 java.lang.Object readObject(int kind, Type type)
           
 PersistenceCapable readPersistentObject()
           
 long readPersistentObjectId()
           
 Shareable readSharedObject()
           
 java.lang.String readString()
           
 PersistenceCapable resolveId(long inputId)
           
 void setNested(boolean nested)
           
 
Methods inherited from class de.grogra.util.HierarchicalQueue.Reader
available, enter, isAt, leave, moveTo, moveToCurrent, next, peekByte, peekDouble, peekFloat, peekInt, peekLong, peekObject, popCursor, previous, pushCursor, read, read, read, readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readInt, readItem, readLine, readLong, readObject, readObjectInQueue, readObjectInStream, readShort, readSkipBlock, readUnsignedByte, readUnsignedShort, readUTF, resetCursor, skip, skipBlock, skipBoolean, skipByte, skipBytes, skipChar, skipDouble, skipFloat, skipInt, skipLong, skipObjectInQueue, skipShort, skipUTF
 
Methods inherited from class java.io.InputStream
mark, markSupported, reset
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface de.grogra.persistence.PersistenceInput
readBoolean, readByte, readChar, readDouble, readFloat, readInt, readLong, readShort, readUnsignedByte, readUnsignedShort
 

Constructor Detail

XAQueue.Reader

protected XAQueue.Reader()
Method Detail

areFieldsProvided

public boolean areFieldsProvided()
Specified by:
areFieldsProvided in interface PersistenceInput

beginArray

public int beginArray()
               throws java.io.IOException
Specified by:
beginArray in interface PersistenceInput
Throws:
java.io.IOException

beginComponent

public boolean beginComponent(ManageableType.ArrayComponent c,
                              int index)
Specified by:
beginComponent in interface PersistenceInput

beginField

public ManageableType.Field beginField(ManageableType type,
                                       ManageableType.Field field)
Specified by:
beginField in interface PersistenceInput

beginManaged

public ManageableType beginManaged()
                            throws java.io.IOException
Specified by:
beginManaged in interface PersistenceInput
Throws:
java.io.IOException

close

public void close()
Specified by:
close in interface java.io.Closeable
Specified by:
close in interface java.io.ObjectInput
Overrides:
close in class HierarchicalQueue.Reader

endArray

public void endArray()
Specified by:
endArray in interface PersistenceInput

endComponent

public void endComponent()
Specified by:
endComponent in interface PersistenceInput

endField

public void endField()
Specified by:
endField in interface PersistenceInput

endManaged

public void endManaged()
Specified by:
endManaged in interface PersistenceInput

getBindings

public final PersistenceBindings getBindings()
Specified by:
getBindings in interface PersistenceInput

getNextObjectKind

public int getNextObjectKind()
Specified by:
getNextObjectKind in interface PersistenceInput

getQueue

public XAQueue getQueue()

open

public void open()

readName

public java.lang.String readName()
                          throws java.io.UTFDataFormatException
Specified by:
readName in interface PersistenceInput
Throws:
java.io.UTFDataFormatException

readObject

public java.lang.Object readObject(int kind,
                                   Type type)
                            throws java.io.IOException
Specified by:
readObject in interface PersistenceInput
Throws:
java.io.IOException

readPersistentObject

public final PersistenceCapable readPersistentObject()
                                              throws java.io.IOException
Specified by:
readPersistentObject in interface PersistenceInput
Throws:
java.io.IOException

readPersistentObjectId

public final long readPersistentObjectId()
                                  throws java.io.IOException
Specified by:
readPersistentObjectId in interface PersistenceInput
Throws:
java.io.IOException

readSharedObject

public final Shareable readSharedObject()
                                 throws java.io.IOException
Specified by:
readSharedObject in interface PersistenceInput
Throws:
java.io.IOException

readString

public java.lang.String readString()
                            throws java.io.UTFDataFormatException
Specified by:
readString in interface PersistenceInput
Throws:
java.io.UTFDataFormatException

resolveId

public PersistenceCapable resolveId(long inputId)
Specified by:
resolveId in interface PersistenceInput

setNested

public void setNested(boolean nested)
Specified by:
setNested in interface PersistenceInput