Subversion Repositories SmartDukaan

/******************************************************************************* 
 *  Copyright 2008-2012 Amazon.com, Inc. or its affiliates. All Rights Reserved.
 *  Licensed under the Apache License, Version 2.0 (the "License"); 
 *  
 *  You may not use this file except in compliance with the License. 
 *  You may obtain a copy of the License at: http://aws.amazon.com/apache2.0
 *  This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR 
 *  CONDITIONS OF ANY KIND, either express or implied. See the License for the 
 *  specific language governing permissions and limitations under the License.
 * ***************************************************************************** 
 * 
 *  Marketplace Web Service Orders Java Library
 *  API Version: 2011-01-01
 * 
 */



package com.amazonservices.mws.orders.samples;

import java.util.List;
import java.util.ArrayList;
import com.amazonservices.mws.orders.*;
import com.amazonservices.mws.orders.model.*;
import java.util.concurrent.Future;
import java.util.concurrent.Executors;
import java.util.concurrent.ExecutorService;

/**
 *
 * List Orders  Samples
 *
 *
 */
public class ListOrdersAsyncSample {

    /**
     * Just add few required parameters, and try the service
     * List Orders functionality
     *
     * @param args unused
     */
    public static void main(String... args) {
        
         ExecutorService executor = Executors.newFixedThreadPool(100);
         MarketplaceWebServiceOrdersAsync service = new MarketplaceWebServiceOrdersAsyncClient(
                                        OrdersConfig.accessKeyId, 
                                        OrdersConfig.secretAccessKey, 
                                        OrdersConfig.applicationName, 
                                        OrdersConfig.applicationVersion, 
                                        OrdersConfig.config,
                                        executor);

        /************************************************************************
         * Setup requests parameters and invoke parallel processing. Of course
         * in real world application, there will be much more than a couple of
         * requests to process.
         ***********************************************************************/
         ListOrdersRequest requestOne = new ListOrdersRequest();
         // @TODO: set request parameters here

         ListOrdersRequest requestTwo = new ListOrdersRequest();
         // @TODO: set second request parameters here

         List<ListOrdersRequest> requests = new ArrayList<ListOrdersRequest>();
         requests.add(requestOne);
         requests.add(requestTwo);

         invokeListOrders(service, requests);

         executor.shutdown();

    }


                                        
    /**
     * List Orders request sample
     * ListOrders can be used to find orders that meet the specified criteria.
     *   
     * @param service instance of MarketplaceWebServiceOrders service
     * @param requests list of requests to process
     */
    public static void invokeListOrders(MarketplaceWebServiceOrdersAsync service, List<ListOrdersRequest> requests) {
        List<Future<ListOrdersResponse>> responses = new ArrayList<Future<ListOrdersResponse>>();
        for (ListOrdersRequest request : requests) {
            responses.add(service.listOrdersAsync(request));
        }
        for (Future<ListOrdersResponse> future : responses) {
            while (!future.isDone()) {
                Thread.yield();
            }
            try {
                ListOrdersResponse response = future.get();
                // Original request corresponding to this response, if needed:
                ListOrdersRequest originalRequest = requests.get(responses.indexOf(future));
                System.out.println("Response request id: " + response.getResponseMetadata().getRequestId());
            } catch (Exception e) {
                if (e.getCause() instanceof MarketplaceWebServiceOrdersException) {
                    MarketplaceWebServiceOrdersException exception = MarketplaceWebServiceOrdersException.class.cast(e.getCause());
                    System.out.println("Caught Exception: " + exception.getMessage());
                    System.out.println("Response Status Code: " + exception.getStatusCode());
                    System.out.println("Error Code: " + exception.getErrorCode());
                    System.out.println("Error Type: " + exception.getErrorType());
                    System.out.println("Request ID: " + exception.getRequestId());
                    System.out.println("XML: " + exception.getXML());
                    System.out.print("ResponseHeaderMetadata: " + exception.getResponseHeaderMetadata());
                } else {
                    e.printStackTrace();
                }
            }
        }
    }
        
}