Subversion Repositories SmartDukaan

/******************************************************************************* 

 *  Copyright 2009 Amazon Services.

 *  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 Java Library

 *  API Version: 2009-01-01

 *  Generated: Wed Feb 18 13:28:48 PST 2009 

 * 

 */

package com.amazonaws.mws.samples;

import java.io.ByteArrayInputStream;

import java.util.List;

import java.util.ArrayList;

import com.amazonaws.mws.*;

import com.amazonaws.mws.model.*;

import java.util.concurrent.Future;

/**

 *

 * Submit Feed  Samples

 *

 *

 */

public class SubmitFeedAsyncSample {

    /**

     * Just add a few required parameters, and try the service

     * Submit Feed functionality

     *

     * @param args unused

     */

    public static void main(String... args) {

        /************************************************************************

         * Access Key ID and Secret Access Key ID, obtained from:

         * http://aws.amazon.com

         ***********************************************************************/

        final String accessKeyId = "<Your Access Key ID>";

        final String secretAccessKey = "<Your Secret Access Key>";

        final String appName = "<Your Application or Company Name>";

        final String appVersion = "<Your Application Version or Build Number or Release Date>";

        MarketplaceWebServiceConfig config = new MarketplaceWebServiceConfig();

        /************************************************************************

         * Uncomment to set the appropriate MWS endpoint.

         ************************************************************************/

        // US

        // config.setServiceURL("https://mws.amazonservices.com");

        // UK

        // config.setServiceURL("https://mws.amazonservices.co.uk");

        // Germany

        // config.setServiceURL("https://mws.amazonservices.de");

        // France

        // config.setServiceURL("https://mws.amazonservices.fr");

        // Italy

        // config.setServiceURL("https://mws.amazonservices.it");

        // Japan

        // config.setServiceURL("https://mws.amazonservices.jp");

        // China

        // config.setServiceURL("https://mws.amazonservices.com.cn");

        // Canada

        // config.setServiceURL("https://mws.amazonservices.ca");

        // India

        // config.setServiceURL("https://mws.amazonservices.in");

        /************************************************************************

         * The argument (35) set below is the number of threads client should

         * spawn for processing.

         ***********************************************************************/

        config.setMaxAsyncThreads(35);

        /************************************************************************

         * You can also try advanced configuration options. Available options are:

         *

         *  - Signature Version

         *  - Proxy Host and Proxy Port

         *  - User Agent String to be sent to Marketplace Web Service

         *

         ***********************************************************************/

        /************************************************************************

         * Instantiate Http Client Implementation of Marketplace Web Service        

         ***********************************************************************/

        MarketplaceWebService service = new MarketplaceWebServiceClient(

                accessKeyId, secretAccessKey, appName, appVersion, config);

        /************************************************************************

         * 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.

         ***********************************************************************/

        /************************************************************************

         * Marketplace and Merchant IDs are required parameters for all 

         * Marketplace Web Service calls.

         ***********************************************************************/

        final String merchantId = "<Your Merchant ID>";

        SubmitFeedRequest requestOne = new SubmitFeedRequest();

        requestOne.setMerchant( merchantId );

        requestOne.setFeedType( "<Feed Type>" );

        // MWS exclusively offers a streaming interface for uploading your feeds. This is because 

        // feed sizes can grow past the 1GB range - and as your business grows you could otherwise 

        // silently reach the feed size where your in-memory solution will no longer work, leaving you 

        // puzzled as to why a solution that worked for a long time suddenly stopped working though 

        // you made no changes. For the same reason, we strongly encourage you to generate your feeds to 

        // local disk then upload them directly from disk to MWS via Java - without buffering them in Java 

        // memory in their entirety.

        //

        // requestOne.setFeedContent( new FileInputStream("my-feed-1.xml" /*or "my-flat-file-1.txt" if you use flat files*/);

        SubmitFeedRequest requestTwo = new SubmitFeedRequest();

        requestTwo.setMerchant( merchantId );

        requestTwo.setFeedType( "<Feed Type>" );

        // requestTwo.setFeedContent( new FileInputStream("my-feed-2.xml" /*or "my-flat-file-2.txt" if you use flat files*/);

        List<SubmitFeedRequest> requests = new ArrayList<SubmitFeedRequest>();

        requests.add(requestOne);

        requests.add(requestTwo);

        // invokeSubmitFeed(service, requests);

    }

    /**

     * Submit Feed request sample

     * Uploads a file for processing together with the necessary

     * metadata to process the file, such as which type of feed it is.

     * PurgeAndReplace if true means that your existing e.g. inventory is

     * wiped out and replace with the contents of this feed - use with

     * caution (the default is false).

     *   

     * @param service instance of MarketplaceWebService service

     * @param requests list of requests to process

     */

    public static void invokeSubmitFeed(MarketplaceWebService service, List<SubmitFeedRequest> requests) {

        List<Future<SubmitFeedResponse>> responses = new ArrayList<Future<SubmitFeedResponse>>();

        for (SubmitFeedRequest request : requests) {

            responses.add(service.submitFeedAsync(request));

        }

        for (Future<SubmitFeedResponse> future : responses) {

            while (!future.isDone()) {

                Thread.yield();

            }

            try {

                SubmitFeedResponse response = future.get();

                // Original request corresponding to this response, if needed:

                SubmitFeedRequest originalRequest = requests.get(responses.indexOf(future));

                System.out.println("Response request id: " + response.getResponseMetadata().getRequestId());

                System.out.println(response.getResponseHeaderMetadata());

                System.out.println();

            } catch (Exception e) {

                if (e.getCause() instanceof MarketplaceWebServiceException) {

                    MarketplaceWebServiceException exception = MarketplaceWebServiceException.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.print("XML: " + exception.getXML());

                    System.out.println("ResponseHeaderMetadata: " + exception.getResponseHeaderMetadata());

                } else {

                    e.printStackTrace();

                }

            }

        }

    }

}