|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.io.OutputStream
org.activemq.streams.JMSOutputStream
OutputStream that writes on to JMS via the supplied JMS MessageProducer
Constructor Summary | |
JMSOutputStream(MessageProducer producer)
Creates a new output stream to write data using the supplied JMS MessageProducer |
|
JMSOutputStream(MessageProducer producer,
int size)
Creates a new output stream to write data using the supplied JMS MessageProducer |
Method Summary | |
protected void |
checkClosed()
Checks that the stream has not been closed |
void |
close()
close this stream |
void |
flush()
flush the data to the output stream This doesn't call flush on the underlying outputstream, because Tcp is particularly efficent at doing this itself .... |
void |
write(byte[] b,
int off,
int len)
write a byte array to the stream |
void |
write(int b)
write a byte on to the stream |
Methods inherited from class java.io.OutputStream |
write |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public JMSOutputStream(MessageProducer producer)
producer
- public JMSOutputStream(MessageProducer producer, int size)
producer
- size
- the buffer size.
IllegalArgumentException
- if size <= 0.Method Detail |
public void write(int b) throws IOException
b
- - byte to write
IOException
public void write(byte[] b, int off, int len) throws IOException
b
- the byte bufferoff
- the offset into the bufferlen
- the length of data to write
IOException
public void flush() throws IOException
IOException
public void close() throws IOException
IOException
protected void checkClosed() throws IOException
IOException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |