SimpleMessageSender.java



/** MessageSender の拡張の試作版のクラス */
import java.io.*;
import java.rmi.*;
public class SimpleMessageSender extends MessageSender {

  /** 標準入力の先 */
    public BufferedReader input;

  /** 自分の名前 */
    public String myName;

  /** コンストラクタ */
    public SimpleMessageSender( String serverName, String myName )
                                     throws RemoteException {
        super( serverName );
        this.myName = myName;
        try {
            input = new BufferedReader(
                       new InputStreamReader( System.in ) );
        }
        catch( Exception e ) {
            System.out.println( "Error:" + e.toString() );
        }
    }

  /** 標準入力からのメッセージを処理するメソッド */
    public void inputLoop() throws RemoteException {
        try {
            while( true ) {
                String line = input.readLine();
                Message message = new Message( myName, line );
                sendMessage( message );
            }
        }
        catch( RemoteException e ) {
            throw e;
        }
        catch( Exception e ) {
            System.out.println( "Error:" + e.toString() );
        }
    }
}