|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.io.InputStream
org.activemq.streams.JMSInputStream
An inputStream that reads data from a MessageConsumer
Field Summary | |
protected ByteArray[] |
arrays
|
protected int |
clen
|
Constructor Summary | |
JMSInputStream(MessageConsumer consumer)
Construct an input stream to read from a JMS Consumer |
Method Summary | |
int |
available()
Return the number of bytes available for reading. |
void |
close()
close the stream and the MessageConsumer |
void |
mark(int readlimit)
Set the stream's mark to the current position. |
boolean |
markSupported()
|
int |
read()
Read the next byte from this stream. |
int |
read(byte[] b)
Read data from this input stream into the given byte array starting at offset 0 for b.length bytes. |
int |
read(byte[] b,
int off,
int len)
Read data from this input stream into the given byte array starting at offset 'off' for 'len' bytes. |
void |
reset()
Returns the stream to the position of the previous mark(). |
long |
skip(long length)
Skip n bytes in this stream; returns the number of bytes actually skipped (which may be less than the number requested). |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected ByteArray[] arrays
protected int clen
Constructor Detail |
public JMSInputStream(MessageConsumer consumer)
consumer
- Method Detail |
public int read() throws IOException
IOException
public int read(byte[] b) throws IOException
b
-
IOException
public int read(byte[] b, int off, int len) throws IOException
b
- buffer to read data intooff
- offset into blen
- the maximum length
IOException
public long skip(long length) throws IOException
length
- the number of bytes to skip
IOException
public int available() throws IOException
IOException
public void close()
public boolean markSupported()
public void reset() throws IOException
IOException
public void mark(int readlimit)
readlimit
-
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |