Sample Code (Asynchronous Request)

The following example illustrates the steps you take to submit an asynchronous request to the Job Manager. To submit an asynchronous request, you establish a connection and start a transaction just like you do for a synchronous request. However, you submit the request using the submitTX method instead of the invokeTx method. Then, you must retrieve the results of the request using the retrieveIDTx method (to get results as an IData object).

   String privkey = "./config/privKey1.der";
   String[] certFiles = {"./config/cert1.der","./config/cacert1.der"};
   // initialize TContext and establish connection attributes
   try {
    TContext.init("./jobs", "./tx.log");
    tc = new TContext();
    tc.connect("localhost:5555", "Administrator", "manage");
    tc.setSecure(true);
    tc.setSSLCertificates(privKey,certFiles);
   } catch (ServiceException e) {
    System.err.println("Error: "+e.getMessage());
    System.exit(-1);   }
   // do work with TContext - get tid, call service, end tid
   try {
    String tid = tc.startTx(3);

    // Make an asynch call to invoke the specified transaction.
    tc.submitTx(tid, "wm.server", "ping", IDataFactory.create());

    // Retrieve the results of an asynch call in blocking mode.
    IData result = tc.retrieveTx(tid);

    System.out.println("Result="+result.toString());
    tc.endTx(tid);
   } catch (TXException e) {
    System.err.println("Job Failed: "+e.getMessage());
    System.exit(-1);
   } catch (DeliveryException e) {
    System.err.println("JobMgr Disabled: "+e.getMessage());
    System.exit(-1);
   } catch (AccessException e) {
    System.err.println("Access Denied: "+e.getMessage());
    System.exit(-1);
   } catch (ServiceException e) {
    System.err.println("Error: "+e.getMessage());
    System.exit(-1);
   }
   // release connection and shutdown
   tc.disconnect();
   TContext.shutdown();
  }
}