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



package examples.message;

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

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

      // create two listeners capable of getting a callback when the invocation completes
      ResultListener[] listeners = new ResultListener[ 2 ];
      listeners[ 0 ] = new MyResultListener();
      listeners[ 1 ] = new MyResultListener();

      // add as a listener to the result of the future invocation
      System.out.println( "send delay( 5000 )" );
      Result result = Future.invoke( alarm, "delay", new Object[]{ new Integer( 5000 ) }, false, 0, listeners );
      System.out.println( "value = " + result.readInt() );
      }
    catch( Exception exception )
      {
      System.err.println( exception );
      }

    Voyager.shutdown();
    }
  }

class MyResultListener implements ResultListener
  {
  public void resultReceived( ResultEvent event )
    {
    System.out.println( "listener gets result event" );
    System.out.println( "event source = " + event.getSource() );
    System.out.println( "object = " + event.getObject() );
    System.out.println( "exception = " + event.isException() );
    }
  }