Class RoutingInputStream

java.lang.Object
  |
  +--java.io.InputStream
        |
        +--java.io.FilterInputStream
              |
              +--java.io.DataInputStream
                    |
                    +--MessageInput
                          |
                          +--RoutingInputStream

public class RoutingInputStream

extends MessageInput

Field Summary

protected MessageInput	messageIn
protected java.lang.String[]	targets

Fields inherited from class java.io.DataInputStream

lineBuffer

Fields inherited from class java.io.FilterInputStream

in

Fields inherited from class java.io.InputStream

SKIP_BUFFER_SIZE, skipBuffer

Constructor Summary

RoutingInputStream(MessageInput messageIn)

Method Summary

java.lang.String[]	getTargets()
void	receive()

Methods inherited from class java.io.DataInputStream

read, read, readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readInt, readLine, readLong, readShort, readUnsignedByte, readUnsignedShort, readUTF, readUTF, skipBytes

Methods inherited from class java.io.FilterInputStream

available, close, mark, markSupported, read, reset, skip

Methods inherited from class java.lang.Object

, clone, equals, finalize, getClass, hashCode, notify, notifyAll, registerNatives, toString, wait, wait, wait

Field Detail

messageIn

protected MessageInput messageIn

targets

protected java.lang.String[] targets

Constructor Detail

RoutingInputStream

public RoutingInputStream(MessageInput messageIn)

Method Detail

receive

public void receive()
             throws java.io.IOException

Overrides:

receive in class MessageInput

getTargets

public java.lang.String[] getTargets()