Class prominence.msg.QueueOutputStream 
All Packages  Class Hierarchy  This Package  Previous  Next  Index

Class prominence.msg.QueueOutputStream 

java.lang.Object
   |
   +----java.io.OutputStream
           |
           +----java.io.FilterOutputStream
                   |
                   +----java.io.DataOutputStream
                           |
                           +----prominence.msg.MessageOutput
                                   |
                                   +----prominence.msg.QueueOutputStream
public class QueueOutputStream
extends MessageOutput
A MessageOutput that inserts messages into a Queue of byte arrays.
See Also:
QueueInputStream

Variable Index

o byteO
A ByteArrayOutputStream used to buffer the current message contents.
o q
The Queue of messages.

Constructor Index

o QueueOutputStream(Queue)
Creates a new QueueOutputStream.

Method Index

o send()
Inserts the current message buffer into the Queue.

Variables

o byteO 
  protected ByteArrayOutputStream byteO
A ByteArrayOutputStream used to buffer the current message contents.
o q 
  protected Queue q
The Queue of messages.

Constructors

o QueueOutputStream 
  public QueueOutputStream(Queue q)
Creates a new QueueOutputStream.
Parameters:
q - A Queue into which messages will be written

Methods

o send 
  public void send()
Inserts the current message buffer into the Queue.
Overrides:
send in class MessageOutput 
All Packages  Class Hierarchy  This Package  Previous  Next  Index