// (c) Copyright 1997-2001 Recursion Software Inc.



package examples.message;

import com.recursionsw.ve.*;
import com.recursionsw.ve.message.*;

public class Message3
  {
  public static void main( String args[] )
    {
    try
      {
      Voyager.startup();
      IAlarm alarm = (IAlarm) Factory.create( "examples.message.Alarm", "//localhost:8000" );

      // demonstrate blocking reads
      try
        {
        System.out.println( "about to send delay( 5000 )" );
        Result result = Future.invoke( alarm, "delay", new Object[]{ new Integer( 5000 ) } );

        // check to see if the return value is available
        System.out.println( "available = " + result.isAvailable() );

        // execute a blocking read for the return value
        int value = result.readInt();

        // display the return value and the current status of the result
        System.out.println( "result = " + value );
        System.out.println( "available = " + result.isAvailable() );
        System.out.println( "exception = " + result.isException() );
        }
      catch( Exception exception )
        {
        System.err.println( "alarm.delay( 5000 ) -> " + exception );
        }

      // demonstrate a thrown exception
      try
        {
        System.out.println( "about to send delay( -1 )" );
        Result result = Future.invoke( alarm, "delay", new Object[]{ new Integer( -1 ) } );
        int value = result.readInt();
        System.out.println( "result = " + value );
        }
      catch( Exception exception )
        {
        System.err.println( "alarm.delay( -1 ) -> " + exception );
        }
      }
    catch( Exception exception )
      {
      System.err.println( exception );
      }

    Voyager.shutdown();
    }
  }