public class HessianInput extends AbstractHessianInput
HessianInput is unbuffered, so any client needs to provide its own buffering.
InputStream is = ...; // from http connection HessianInput in = new HessianInput(is); String value; in.startReply(); // read reply header value = in.readString(); // read string value in.completeReply(); // read reply footer
Modifier and Type | Field and Description |
---|---|
protected int |
_peek |
protected java.util.ArrayList |
_refs |
protected SerializerFactory |
_serializerFactory |
Constructor and Description |
---|
HessianInput()
Creates an uninitialized Hessian input stream.
|
HessianInput(java.io.InputStream is)
Creates a new Hessian input stream, initialized with an
underlying input stream.
|
Modifier and Type | Method and Description |
---|---|
int |
addRef(java.lang.Object ref)
Adds a list/map reference.
|
void |
close() |
protected java.lang.String |
codeName(int ch) |
void |
completeCall()
Completes reading the call
|
void |
completeReply()
Completes reading the call
|
void |
completeValueReply()
Completes reading the call
|
protected java.io.IOException |
error(java.lang.String message) |
protected java.io.IOException |
expect(java.lang.String expect,
int ch) |
java.lang.String |
getMethod()
Returns the calls method
|
java.io.Reader |
getReader()
Starts reading a string.
|
java.lang.Throwable |
getReplyFault()
Returns any reply fault.
|
SerializerFactory |
getSerializerFactory()
Gets the serializer factory.
|
void |
init(java.io.InputStream is)
Initialize the hessian stream with the underlying input stream.
|
boolean |
isEnd()
Returns true if this is the end of a list or a map.
|
boolean |
readBoolean()
Reads a boolean
|
int |
readByte()
Reads a byte from the stream.
|
byte[] |
readBytes()
Reads a byte array
|
int |
readBytes(byte[] buffer,
int offset,
int length)
Reads a byte array from the stream.
|
int |
readCall()
Starts reading the call
|
int |
readChar()
Reads a byte from the stream.
|
double |
readDouble()
Reads a double
|
void |
readEnd()
Reads the end byte.
|
float |
readFloat()
Reads a float
|
java.lang.String |
readHeader()
Reads a header, returning null if there are no headers.
|
java.io.InputStream |
readInputStream()
Reads bytes based on an input stream.
|
int |
readInt()
Reads an integer
|
int |
readLength()
Parses the length for an array
|
void |
readListEnd()
Reads the end byte.
|
int |
readListStart()
Reads the start of a list.
|
long |
readLong()
Reads a long
|
void |
readMapEnd()
Reads the end byte.
|
int |
readMapStart()
Reads the start of a list.
|
java.lang.String |
readMethod()
Starts reading the call
|
org.w3c.dom.Node |
readNode()
Reads an XML node.
|
void |
readNull()
Reads a null
|
java.lang.Object |
readObject()
Reads an arbitrary object from the input stream when the type
is unknown.
|
java.lang.Object |
readObject(java.lang.Class cl)
Reads an object from the input stream with an expected type.
|
java.lang.Object |
readRef()
Reads a reference.
|
java.lang.Object |
readRemote()
Reads a remote object.
|
java.lang.Object |
readReply(java.lang.Class expectedClass)
Reads a reply as an object.
|
short |
readShort()
Reads a short
|
java.lang.String |
readString()
Reads a string
|
int |
readString(char[] buffer,
int offset,
int length)
Reads a byte array from the stream.
|
java.lang.String |
readType()
Parses a type from the stream.
|
long |
readUTCDate()
Reads a date.
|
void |
resetReferences()
Resets the references for streaming.
|
java.lang.Object |
resolveRemote(java.lang.String type,
java.lang.String url)
Resolves a remote object.
|
void |
setRef(int i,
java.lang.Object ref)
Adds a list/map reference.
|
void |
setSerializerFactory(SerializerFactory factory)
Sets the serializer factory.
|
void |
skipOptionalCall()
For backward compatibility with HessianSkeleton
|
void |
startCall()
Starts reading the call, including the headers.
|
void |
startReply()
Starts reading the reply
|
void |
startReplyBody()
Starts reading the body of the reply, i.e.
|
getRemoteResolver, readMethodArgLength, readToOutputStream, setRemoteResolver
protected SerializerFactory _serializerFactory
protected java.util.ArrayList _refs
protected int _peek
public HessianInput()
public HessianInput(java.io.InputStream is)
is
- the underlying input stream.public void setSerializerFactory(SerializerFactory factory)
setSerializerFactory
in class AbstractHessianInput
public SerializerFactory getSerializerFactory()
public void init(java.io.InputStream is)
init
in class AbstractHessianInput
public java.lang.String getMethod()
getMethod
in class AbstractHessianInput
public java.lang.Throwable getReplyFault()
public int readCall() throws java.io.IOException
c major minor
readCall
in class AbstractHessianInput
java.io.IOException
public void skipOptionalCall() throws java.io.IOException
skipOptionalCall
in class AbstractHessianInput
java.io.IOException
public java.lang.String readMethod() throws java.io.IOException
A successful completion will have a single value:
m b16 b8 method
readMethod
in class AbstractHessianInput
java.io.IOException
public void startCall() throws java.io.IOException
The call expects the following protocol data
c major minor m b16 b8 method
startCall
in class AbstractHessianInput
java.io.IOException
public void completeCall() throws java.io.IOException
A successful completion will have a single value:
z
completeCall
in class AbstractHessianInput
java.io.IOException
public java.lang.Object readReply(java.lang.Class expectedClass) throws java.lang.Throwable
readReply
in class AbstractHessianInput
java.lang.Throwable
public void startReply() throws java.lang.Throwable
A successful completion will have a single value:
r
startReply
in class AbstractHessianInput
java.lang.Throwable
public void startReplyBody() throws java.lang.Throwable
AbstractHessianInput
startReplyBody
in class AbstractHessianInput
java.lang.Throwable
public void completeReply() throws java.io.IOException
A successful completion will have a single value:
z
completeReply
in class AbstractHessianInput
java.io.IOException
public void completeValueReply() throws java.io.IOException
A successful completion will have a single value:
z
java.io.IOException
public java.lang.String readHeader() throws java.io.IOException
H b16 b8 value
readHeader
in class AbstractHessianInput
java.io.IOException
public void readNull() throws java.io.IOException
N
readNull
in class AbstractHessianInput
java.io.IOException
public boolean readBoolean() throws java.io.IOException
T F
readBoolean
in class AbstractHessianInput
java.io.IOException
public short readShort() throws java.io.IOException
I b32 b24 b16 b8
java.io.IOException
public int readInt() throws java.io.IOException
I b32 b24 b16 b8
readInt
in class AbstractHessianInput
java.io.IOException
public long readLong() throws java.io.IOException
L b64 b56 b48 b40 b32 b24 b16 b8
readLong
in class AbstractHessianInput
java.io.IOException
public float readFloat() throws java.io.IOException
D b64 b56 b48 b40 b32 b24 b16 b8
java.io.IOException
public double readDouble() throws java.io.IOException
D b64 b56 b48 b40 b32 b24 b16 b8
readDouble
in class AbstractHessianInput
java.io.IOException
public long readUTCDate() throws java.io.IOException
T b64 b56 b48 b40 b32 b24 b16 b8
readUTCDate
in class AbstractHessianInput
java.io.IOException
public int readChar() throws java.io.IOException
java.io.IOException
public int readString(char[] buffer, int offset, int length) throws java.io.IOException
java.io.IOException
public java.lang.String readString() throws java.io.IOException
S b16 b8 string value
readString
in class AbstractHessianInput
java.io.IOException
public org.w3c.dom.Node readNode() throws java.io.IOException
S b16 b8 string value
readNode
in class AbstractHessianInput
java.io.IOException
public byte[] readBytes() throws java.io.IOException
B b16 b8 data value
readBytes
in class AbstractHessianInput
java.io.IOException
public int readByte() throws java.io.IOException
java.io.IOException
public int readBytes(byte[] buffer, int offset, int length) throws java.io.IOException
java.io.IOException
public java.lang.Object readObject(java.lang.Class cl) throws java.io.IOException
readObject
in class AbstractHessianInput
cl
- the expected class if the protocol doesn't supply it.java.io.IOException
public java.lang.Object readObject() throws java.io.IOException
readObject
in class AbstractHessianInput
java.io.IOException
public java.lang.Object readRemote() throws java.io.IOException
readRemote
in class AbstractHessianInput
java.io.IOException
public java.lang.Object readRef() throws java.io.IOException
readRef
in class AbstractHessianInput
java.io.IOException
public int readListStart() throws java.io.IOException
readListStart
in class AbstractHessianInput
java.io.IOException
public int readMapStart() throws java.io.IOException
readMapStart
in class AbstractHessianInput
java.io.IOException
public boolean isEnd() throws java.io.IOException
isEnd
in class AbstractHessianInput
java.io.IOException
public void readEnd() throws java.io.IOException
readEnd
in class AbstractHessianInput
java.io.IOException
public void readMapEnd() throws java.io.IOException
readMapEnd
in class AbstractHessianInput
java.io.IOException
public void readListEnd() throws java.io.IOException
readListEnd
in class AbstractHessianInput
java.io.IOException
public int addRef(java.lang.Object ref)
addRef
in class AbstractHessianInput
public void setRef(int i, java.lang.Object ref)
setRef
in class AbstractHessianInput
public void resetReferences()
resetReferences
in class AbstractHessianInput
public java.lang.Object resolveRemote(java.lang.String type, java.lang.String url) throws java.io.IOException
java.io.IOException
public java.lang.String readType() throws java.io.IOException
t b16 b8
readType
in class AbstractHessianInput
java.io.IOException
public int readLength() throws java.io.IOException
l b32 b24 b16 b8
readLength
in class AbstractHessianInput
java.io.IOException
public java.io.InputStream readInputStream() throws java.io.IOException
readInputStream
in class AbstractHessianInput
java.io.IOException
public void close()
close
in class AbstractHessianInput
public java.io.Reader getReader()
AbstractHessianInput
s b16 b8 non-final string chunk S b16 b8 final string chunk
getReader
in class AbstractHessianInput
protected java.io.IOException expect(java.lang.String expect, int ch)
protected java.lang.String codeName(int ch)
protected java.io.IOException error(java.lang.String message)