XINS - Asynchronous calls (by Anthony Goubard)

// Create the Client API. The CAPI will be used to call the API.
CAPI capi = new CAPI(descriptor);

int customerId = 12345654;

// Create and start the thread that calls the AccountDetails function
AccountDetailsThread callThread = new AccountDetailsThread(capi, customerId);
callAccountDetails.start();

// You don't need to create another thread to call the address details,
// just use the current thread
AddressDetailsResult addressDetails = capi.callAddressDetails(customerId);

// Wait for the AccountDetails function to finish (if it has not finished yet)
// If you are not interested in the response of the call,
// you can remove the call to the join() method
callAccountDetails.join();

AccountDetailsResult accountDetails = null;
if (callAccountDetails.getException() != null) {
   throw callAccountDetails.getException();
} else {
   accountDetails = callAccountDetails.getResult();
}

// Congratulation! At this point, you have the address and account details.


/**
 * Thread that calls the AccountDetails function.
 */
class AccountDetailsThread extends Thread {

   private CAPI _capi;
   private int _id;
   private Exception _exception;
   private AccountDetailsResult _result;

   AccountDetailsThread(CAPI capi, int id {
      _capi = capi;
      _id = id;
   }

   public void run() {
      try {
         _result = _capi.callAccountDetails(_id);
      } catch (Exception ex) {
         _exception = ex;
      }
   }

   public Exception getException() {
      return _exception;
   }

   public AccountDetailsResult getResult() {
      return _result;
   }
}

/**
 * Adds credits to a customer.
 */
class AddCreditsClient implements CallListener {

   public AddCreditsClient(CAPI capi, int credits, int customerID) {
      AsynchronousCall asyncCall = new AsynchronousCall();

      // Register this call in order to be notified when the result arrives
      asyncCall.addCallListener(this);
      AddCreditsRequest request = new AddCreditsRequest();
      request.setCustomerID(customerID);
      request.setCreditsToAdd(credits);

      // Start the call in a separate thread
      asyncCall.call(capi, request);
   }

   public void callSucceeded(CallSucceededEvent event) {
      AddCreditsResult result = (AddCreditsResult) event.getResult();
      AddCreditsRequest request = (AddCreditsRequest) event.getRequest();

      // Here we just show the result, but we could have logged the information
      // or stored it in a database.
      System.out.println("Customer N\u00b0 " + request.getCustomerID() +
            " has been credited. His new credit is $" +
            result.getCustomerCredit() + ".");
   }

   public void callFailed(CallFailedEvent event) {
      AddCreditsRequest request = (AddCreditsRequest) event.getRequest();

      // The reason why the call failed
      Exception exception = event.getException();

      // Depending on the error, we show a different message
      if (exception instanceof UnsuccessfulXINSCallException) {
         System.err.println("Failed to credit the customer N\u00b0 " +
               request.getCustomerID() + ". Error on server side: " +
               ((UnsuccessfulXINSCallException) exception).getErrorCode());
      } else {
         System.err.println("Failed to credit the customer N\u00b0 " +
               request.getCustomerID() + ". Reason: " +
               event.getException().getMessage());
      }
   }
}