FileDocCategorySizeDatePackage
AsyncRequest.javaAPI DocExample3561Mon Dec 02 13:34:04 GMT 2002ora.jwsnut.chapter7.jaxr

AsyncRequest

public class AsyncRequest extends Object

Fields Summary
private static javax.xml.registry.BusinessQueryManager
bqm
Constructors Summary
Methods Summary
private static voiddoAsyncRequest()


        // Request all organizations
        ArrayList namePatterns = new ArrayList();
        namePatterns.add("%");
        BulkResponse res = bqm.findOrganizations(null, namePatterns, null, null, null, null);

	  // Wait until the request has completed
        System.out.println("Request submitted - id = " + res.getRequestId());
        while (!res.isAvailable()) {
            System.out.println("Request status: " + res.getStatus());
            try {
                Thread.sleep(1000);
            } catch (InterruptedException ex) {
            }
        }
        System.out.println("Request completed"); 
        
        // Process results (if any)
        Collection coll = res.getCollection();
        System.out.println("Request found " + coll.size());
        Iterator iter = coll.iterator();
        while (iter.hasNext()) {
            Organization org = (Organization)iter.next();
            System.out.println("\t" + org.getName().getValue());
        }
        
        // Process exceptions (if any)
        Collection exceptions = res.getExceptions();
        if (exceptions != null && !exceptions.isEmpty()){
            System.out.println("Error while searching");
            iter = exceptions.iterator();
            while (iter.hasNext()) {
                ((Exception)iter.next()).printStackTrace(System.out);
            }
        }
public static voidmain(java.lang.String[] args)

        
        // Validate arguments
        if (args.length != 1) {
            usage();
        }
        
        // Process the common arguments
        String queryURL = args[0];
        
        try {
            // Get the ConnectionFactory
            Properties props = new Properties();
            props.put("javax.xml.registry.queryManagerURL", queryURL);
            
            ConnectionFactory cf = ConnectionFactory.newInstance();
            cf.setProperties(props);
            
            // Get and initialize the connection
            Connection conn = cf.createConnection();
            conn.setSynchronous(false);
            
            // Get the RegistryService and the BusinessQueryManager
            RegistryService registry = conn.getRegistryService();
            bqm = registry.getBusinessQueryManager();            

            // Run the example code
            doAsyncRequest();
            
            // Close connection
            conn.close();           
            
        } catch (Throwable t) {
            System.out.println(t);
            t.printStackTrace(System.out);
            System.exit(1);
        }    
        
        System.exit(0);
public static voidusage()

        System.out.println("Usage:\tAsyncRequest queryURL");
        System.exit(1);