Package fr.dyade.aaa.agent
Class HttpNetwork.NetworkInputStream
- java.lang.Object
-
- java.io.InputStream
-
- fr.dyade.aaa.agent.MessageInputStream
-
- fr.dyade.aaa.agent.BufferedMessageInputStream
-
- fr.dyade.aaa.agent.HttpNetwork.NetworkInputStream
-
- All Implemented Interfaces:
Closeable,AutoCloseable
- Enclosing class:
- HttpNetwork
final class HttpNetwork.NetworkInputStream extends BufferedMessageInputStream
Class used to read messages through a stream.
-
-
Field Summary
Fields Modifier and Type Field Description (package private) intack(package private) intboot(package private) Messagemsg-
Fields inherited from class fr.dyade.aaa.agent.BufferedMessageInputStream
in
-
Fields inherited from class fr.dyade.aaa.agent.MessageInputStream
buf, compressedFlows, count, pos
-
-
Constructor Summary
Constructors Constructor Description NetworkInputStream()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) intgetAckStamp()(package private) intgetBootTS()(package private) MessagegetMessage()(package private) intreadFrom(InputStream is, int length)Reads next header or message from inputstreamprotected voidreadHeader()Reads the protocol header from this output stream.-
Methods inherited from class fr.dyade.aaa.agent.BufferedMessageInputStream
clean, read, read, readFully
-
Methods inherited from class fr.dyade.aaa.agent.MessageInputStream
read, readInt, readMessage, readMessageHeader, readShort
-
Methods inherited from class java.io.InputStream
available, close, mark, markSupported, nullInputStream, readAllBytes, readNBytes, readNBytes, reset, skip, transferTo
-
-
-
-
Field Detail
-
boot
int boot
-
ack
int ack
-
msg
Message msg
-
-
Method Detail
-
readHeader
protected void readHeader() throws IOExceptionReads the protocol header from this output stream.- Specified by:
readHeaderin classMessageInputStream- Throws:
IOException- an error occurs.
-
readFrom
int readFrom(InputStream is, int length) throws Exception
Reads next header or message from inputstream. /!\ Be careful, this method always return length or it throws an exception.- Parameters:
is-length-- Returns:
- Throws:
Exception
-
getMessage
Message getMessage()
-
getBootTS
int getBootTS()
-
getAckStamp
int getAckStamp()
-
-