com.purpletech.message
Class StallingPeer

java.lang.Object
  |
  +--com.purpletech.message.AbstractPeer
        |
        +--com.purpletech.message.BlockingPeer
              |
              +--com.purpletech.message.StallingPeer

All Implemented Interfaces:

MessagePeer, java.lang.Runnable

public class StallingPeer

extends BlockingPeer

Field Summary

Fields inherited from class com.purpletech.message.BlockingPeer

host, port

Fields inherited from class com.purpletech.message.AbstractPeer

doSendSystemMessages, listeners, outPrint, printer

Constructor Summary

StallingPeer(java.lang.String host, int port, java.io.PrintStream out, double chance, int min, int max)

Method Summary

java.io.OutputStream

getOutputStream() subclasses can override this to provide filters on the output stream

Methods inherited from class com.purpletech.message.BlockingPeer

connect, disconnect, getHost, getInputStream, getPort, isConnected, receiveMessage, sendMessage

Methods inherited from class com.purpletech.message.AbstractPeer

addMessageListener, bind, getID, lookup, processSystemMessage, removeMessageListener, run, setSendSystemMessages, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

StallingPeer

public StallingPeer(java.lang.String host,
                    int port,
                    java.io.PrintStream out,
                    double chance,
                    int min,
                    int max)

Method Detail

getOutputStream

public java.io.OutputStream getOutputStream()
                                     throws java.io.IOException

Description copied from class: BlockingPeer

subclasses can override this to provide filters on the output stream

Overrides:

getOutputStream in class BlockingPeer

java.io.IOException