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

Class prominence.msg.QueueInputStream 

java.lang.Object
   |
   +----java.io.InputStream
           |
           +----java.io.FilterInputStream
                   |
                   +----java.io.DataInputStream
                           |
                           +----prominence.msg.MessageInput
                                   |
                                   +----prominence.msg.QueueInputStream
public class QueueInputStream
extends MessageInput
A MessageInput that reads messages from a Queue of byte arrays.
See Also:
QueueOutputStream

Variable Index

o q
The Queue of messages.

Constructor Index

o QueueInputStream(Queue)
Creates a new QueueInputStream.

Method Index

o receive()
Extracts a message from the attached Queue and makes it available to read through the usual superclass read() methods.

Variables

o q 
  protected Queue q
The Queue of messages.

Constructors

o QueueInputStream 
  public QueueInputStream(Queue q)
Creates a new QueueInputStream.
Parameters:
q - A Queue out of which messages will be read

Methods

o receive 
  public void receive()
Extracts a message from the attached Queue and makes it available to read through the usual superclass read() methods.
Overrides:
receive in class MessageInput 
All Packages  Class Hierarchy  This Package  Previous  Next  Index