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, setRemoteResolverprotected 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 AbstractHessianInputpublic SerializerFactory getSerializerFactory()
public void init(java.io.InputStream is)
init in class AbstractHessianInputpublic java.lang.String getMethod()
getMethod in class AbstractHessianInputpublic java.lang.Throwable getReplyFault()
public int readCall()
throws java.io.IOException
c major minor
readCall in class AbstractHessianInputjava.io.IOExceptionpublic void skipOptionalCall()
throws java.io.IOException
skipOptionalCall in class AbstractHessianInputjava.io.IOExceptionpublic java.lang.String readMethod()
throws java.io.IOException
A successful completion will have a single value:
m b16 b8 method
readMethod in class AbstractHessianInputjava.io.IOExceptionpublic void startCall()
throws java.io.IOException
The call expects the following protocol data
c major minor m b16 b8 method
startCall in class AbstractHessianInputjava.io.IOExceptionpublic void completeCall()
throws java.io.IOException
A successful completion will have a single value:
z
completeCall in class AbstractHessianInputjava.io.IOExceptionpublic java.lang.Object readReply(java.lang.Class expectedClass)
throws java.lang.Throwable
readReply in class AbstractHessianInputjava.lang.Throwablepublic void startReply()
throws java.lang.Throwable
A successful completion will have a single value:
r
startReply in class AbstractHessianInputjava.lang.Throwablepublic void startReplyBody()
throws java.lang.Throwable
AbstractHessianInputstartReplyBody in class AbstractHessianInputjava.lang.Throwablepublic void completeReply()
throws java.io.IOException
A successful completion will have a single value:
z
completeReply in class AbstractHessianInputjava.io.IOExceptionpublic void completeValueReply()
throws java.io.IOException
A successful completion will have a single value:
z
java.io.IOExceptionpublic java.lang.String readHeader()
throws java.io.IOException
H b16 b8 value
readHeader in class AbstractHessianInputjava.io.IOExceptionpublic void readNull()
throws java.io.IOException
N
readNull in class AbstractHessianInputjava.io.IOExceptionpublic boolean readBoolean()
throws java.io.IOException
T F
readBoolean in class AbstractHessianInputjava.io.IOExceptionpublic short readShort()
throws java.io.IOException
I b32 b24 b16 b8
java.io.IOExceptionpublic int readInt()
throws java.io.IOException
I b32 b24 b16 b8
readInt in class AbstractHessianInputjava.io.IOExceptionpublic long readLong()
throws java.io.IOException
L b64 b56 b48 b40 b32 b24 b16 b8
readLong in class AbstractHessianInputjava.io.IOExceptionpublic float readFloat()
throws java.io.IOException
D b64 b56 b48 b40 b32 b24 b16 b8
java.io.IOExceptionpublic double readDouble()
throws java.io.IOException
D b64 b56 b48 b40 b32 b24 b16 b8
readDouble in class AbstractHessianInputjava.io.IOExceptionpublic long readUTCDate()
throws java.io.IOException
T b64 b56 b48 b40 b32 b24 b16 b8
readUTCDate in class AbstractHessianInputjava.io.IOExceptionpublic int readChar()
throws java.io.IOException
java.io.IOExceptionpublic int readString(char[] buffer,
int offset,
int length)
throws java.io.IOException
java.io.IOExceptionpublic java.lang.String readString()
throws java.io.IOException
S b16 b8 string value
readString in class AbstractHessianInputjava.io.IOExceptionpublic org.w3c.dom.Node readNode()
throws java.io.IOException
S b16 b8 string value
readNode in class AbstractHessianInputjava.io.IOExceptionpublic byte[] readBytes()
throws java.io.IOException
B b16 b8 data value
readBytes in class AbstractHessianInputjava.io.IOExceptionpublic int readByte()
throws java.io.IOException
java.io.IOExceptionpublic int readBytes(byte[] buffer,
int offset,
int length)
throws java.io.IOException
java.io.IOExceptionpublic java.lang.Object readObject(java.lang.Class cl)
throws java.io.IOException
readObject in class AbstractHessianInputcl - the expected class if the protocol doesn't supply it.java.io.IOExceptionpublic java.lang.Object readObject()
throws java.io.IOException
readObject in class AbstractHessianInputjava.io.IOExceptionpublic java.lang.Object readRemote()
throws java.io.IOException
readRemote in class AbstractHessianInputjava.io.IOExceptionpublic java.lang.Object readRef()
throws java.io.IOException
readRef in class AbstractHessianInputjava.io.IOExceptionpublic int readListStart()
throws java.io.IOException
readListStart in class AbstractHessianInputjava.io.IOExceptionpublic int readMapStart()
throws java.io.IOException
readMapStart in class AbstractHessianInputjava.io.IOExceptionpublic boolean isEnd()
throws java.io.IOException
isEnd in class AbstractHessianInputjava.io.IOExceptionpublic void readEnd()
throws java.io.IOException
readEnd in class AbstractHessianInputjava.io.IOExceptionpublic void readMapEnd()
throws java.io.IOException
readMapEnd in class AbstractHessianInputjava.io.IOExceptionpublic void readListEnd()
throws java.io.IOException
readListEnd in class AbstractHessianInputjava.io.IOExceptionpublic int addRef(java.lang.Object ref)
addRef in class AbstractHessianInputpublic void setRef(int i,
java.lang.Object ref)
setRef in class AbstractHessianInputpublic void resetReferences()
resetReferences in class AbstractHessianInputpublic java.lang.Object resolveRemote(java.lang.String type,
java.lang.String url)
throws java.io.IOException
java.io.IOExceptionpublic java.lang.String readType()
throws java.io.IOException
t b16 b8
readType in class AbstractHessianInputjava.io.IOExceptionpublic int readLength()
throws java.io.IOException
l b32 b24 b16 b8
readLength in class AbstractHessianInputjava.io.IOExceptionpublic java.io.InputStream readInputStream()
throws java.io.IOException
readInputStream in class AbstractHessianInputjava.io.IOExceptionpublic void close()
close in class AbstractHessianInputpublic java.io.Reader getReader()
AbstractHessianInputs b16 b8 non-final string chunk S b16 b8 final string chunk
getReader in class AbstractHessianInputprotected 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)