de.ipcon.tools.io

Class QueueOutputStream

java.lang.Object

java.io.OutputStream

de.ipcon.tools.io.QueueOutputStream

All Implemented Interfaces:

java.io.Closeable, java.io.Flushable, java.lang.AutoCloseable

public class QueueOutputStream
extends java.io.OutputStream

Constructor Summary

Constructors

Constructor and Description
QueueOutputStream() Constructs a new instance with a limit 16K for the internal buffer size.

Method Summary

Modifier and Type	Method and Description
void	close()
void	close(boolean viaQueueInputStream)
void	fail(java.lang.Throwable t)
QueueInputStream	getQueueInputStream() Return the QueueInputStream connected to this stream.
boolean	isEmpty()
void	markEmpty(boolean empty)
void	write(int b)

Methods inherited from class java.io.OutputStream

flush, write, write

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QueueOutputStream

public QueueOutputStream()

Constructs a new instance with a limit 16K for the internal buffer size.

Method Detail

getQueueInputStream

public QueueInputStream getQueueInputStream()

Return the QueueInputStream connected to this stream.

Returns:

QueueInputStream connected to this stream

write

public void write(int b)
           throws java.io.IOException

Specified by:

write in class java.io.OutputStream

Throws:

java.io.IOException

markEmpty

public final void markEmpty(boolean empty)

fail

public final void fail(java.lang.Throwable t)

isEmpty

public final boolean isEmpty()

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class java.io.OutputStream

Throws:

java.io.IOException

close

public void close(boolean viaQueueInputStream)
           throws java.io.IOException

Throws:

java.io.IOException