|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.io.InputStream
com.sun.xml.ws.transport.tcp.io.FramedMessageInputStream
public final class FramedMessageInputStream
Stream wrapper around a ByteBuffer
Constructor Summary | |
---|---|
FramedMessageInputStream()
|
|
FramedMessageInputStream(int frameSize)
|
Method Summary | |
---|---|
void |
activate()
|
int |
available()
Return the available bytes |
void |
close()
Close this stream. |
void |
forceHeaderRead()
|
int |
getChannelId()
|
int |
getContentId()
|
java.util.Map<java.lang.Integer,java.lang.String> |
getContentProperties()
|
int |
getMessageId()
|
boolean |
isDirectMode()
|
boolean |
isMessageInProcess()
|
boolean |
markSupported()
Return true if mark is supported. |
void |
passivate()
|
int |
read()
Read the first byte from the wrapped ByteBuffer . |
int |
read(byte[] b)
Read the bytes from the wrapped ByteBuffer . |
int |
read(byte[] b,
int offset,
int length)
Read the first byte of the wrapped ByteBuffer . |
void |
reset()
|
void |
setByteBuffer(java.nio.ByteBuffer byteBuffer)
|
void |
setDirectMode(boolean isDirectMode)
|
void |
setFrameSize(int frameSize)
|
void |
setSocketChannel(java.nio.channels.SocketChannel socketChannel)
|
void |
skipToEndOfMessage()
|
java.lang.String |
toString()
|
Methods inherited from class java.io.InputStream |
---|
mark, skip |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public FramedMessageInputStream()
public FramedMessageInputStream(int frameSize)
Method Detail |
---|
public void setSocketChannel(java.nio.channels.SocketChannel socketChannel)
public int getChannelId()
public int getMessageId()
public int getContentId()
public java.util.Map<java.lang.Integer,java.lang.String> getContentProperties()
public boolean isDirectMode()
public void setDirectMode(boolean isDirectMode)
public void setFrameSize(int frameSize)
public void setByteBuffer(java.nio.ByteBuffer byteBuffer)
public int available()
available
in class java.io.InputStream
public void close()
close
in interface java.io.Closeable
close
in class java.io.InputStream
public boolean markSupported()
markSupported
in class java.io.InputStream
public int read()
ByteBuffer
.
read
in class java.io.InputStream
public int read(byte[] b)
ByteBuffer
.
read
in class java.io.InputStream
public int read(byte[] b, int offset, int length)
ByteBuffer
.
read
in class java.io.InputStream
public void forceHeaderRead() throws java.io.IOException
java.io.IOException
public void skipToEndOfMessage() throws java.io.EOFException
java.io.EOFException
public boolean isMessageInProcess()
public void reset()
reset
in class java.io.InputStream
public void activate()
activate
in interface LifeCycle
public void passivate()
passivate
in interface LifeCycle
public java.lang.String toString()
toString
in class java.lang.Object
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |