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

Class prominence.msg.Demultiplexer 

java.lang.Object
   |
   +----java.lang.Thread
           |
           +----prominence.msg.Demultiplexer
public class Demultiplexer
extends Thread
A class that reads messages from a MultiplexInputStream and forwards them on to the MessageOutput identified by the message label.
See Also:
MessageCopier

Variable Index

o i
The MultiplexInputStream from which messages are read.
o routes
The message routing table.

Constructor Index

o Demultiplexer(MultiplexInputStream)
Creates a new Demultiplexer reading from a specified stream.

Method Index

o deregister(String)
Deregisters a particular message label.
o register(String, MessageOutput)
Registers a MessageOutput as the destination for messages with a particular label.
o run()
Routes messages from the MultiplexInputStream to the MessageOutput identified by their labels.

Variables

o i 
  protected MultiplexInputStream i
The MultiplexInputStream from which messages are read.
o routes 
  protected Hashtable routes
The message routing table. Maps from message labels to MessageOutputs.

Constructors

o Demultiplexer 
  public Demultiplexer(MultiplexInputStream i)
Creates a new Demultiplexer reading from a specified stream.
Parameters:
i - The MultiplexInputStream from which messages should be read

Methods

o register 
  public void register(String label,
                       MessageOutput o)
Registers a MessageOutput as the destination for messages with a particular label.
Parameters:
label - The message label that is to be routed
o - The destination for such messages
o deregister 
  public void deregister(String label)
Deregisters a particular message label.
Parameters:
label - The label that is to be deregistered
o run 
  public void run()
Routes messages from the MultiplexInputStream to the MessageOutput identified by their labels. 
This method
is called by a
new thread when the superclass start() method is called.
  

    
 Overrides:
    
 run in class Thread
    
 See Also:
    
 start
  


All Packages  Class Hierarchy  This Package  Previous  Next  Index