|
||||||||||
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
public class 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
read
in class InputStream
IOException
public int read(byte[] b) throws IOException
read
in class InputStream
b
-
IOException
public int read(byte[] b, int off, int len) throws IOException
read
in class InputStream
b
- buffer to read data intooff
- offset into blen
- the maximum length
IOException
public long skip(long length) throws IOException
skip
in class InputStream
length
- the number of bytes to skip
IOException
public int available() throws IOException
available
in class InputStream
IOException
public void close()
close
in interface Closeable
close
in class InputStream
public boolean markSupported()
markSupported
in class InputStream
public void reset() throws IOException
reset
in class InputStream
IOException
public void mark(int readlimit)
mark
in class InputStream
readlimit
-
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |