WebSVN – SmartDukaan – Diff – /trunk/AmazonOrders/src/main/java/com/amazonservices/mws/orders/samples/FetchOrderUpdatesJob.java

 	 * Add required parameters in OrdersConfig.java before trying out this
 	 * sample.
 	 */
 	public static final Log log = LogFactory.getLog(OrderFetcherSample.class);
-	private volatile boolean keepRunning = true;
+	//private volatile boolean keepRunning = true;
+	private boolean keepRunning = true;
 	/*************************************
 	 * Throttling Limits in Milliseconds *
 	 *************************************/
 	// 1 call per 10 mins
 	static final long LIST_ORDERS_THROTTLE_LIMIT = 600000L;
+	}
 	final public static String AMAZON_ORDER_ACKNOWLEDGEMENT_XML = "/home/vikram/OrderAcknowledgeMent.xml";
-	static final int INTERVAL_IN_MINS = 1; // 1-minute update interval
+	static final int INTERVAL_IN_MINS = 30; // 1-minute update interval
 	//static final int INTERVAL_IN_MINS = 15; // 15-minute update interval
 	protected MarketplaceWebServiceOrders service;
 	protected String sellerId = null;
 				OrdersConfig.config);
 		final FetchOrderUpdatesJob orderFetcher = new FetchOrderUpdatesJob(
 				client, OrdersConfig.sellerId,
 				OrdersConfig.marketplaceIdList);
-		Thread fetchOrderUpdatesJobThread = new Thread(new Runnable() {
+		/*	Thread fetchOrderUpdatesJobThread = new Thread(new Runnable() {
 			public void run() {
 				orderFetcher.startPeriodicSynch();
+			}
 		});
 		 * stopSynch() method is called which stops the job in the second
 		 * thread.
 		 */
 		/*
-		 * TODO: Make sure to change this if you want it to run indefinitely or
+		 *
 		 * for some other length of time .
 		 */
 		try {
+			orderFetcher.startPeriodicSynch();
-			log.info("Main thread sleeping.");
+			//log.info("Main thread sleeping.");
-			Thread.sleep(3600000L); // = 1 hour
+			//Thread.sleep(3600000L); // = 1 hour
-			log.info("Main thread awake.");
+			//log.info("Main thread awake.");
 		} catch (InterruptedException e) {
 			log.error(e.getMessage(), e);
-			return;
+			//return;
+		}
-		log.info("Main thread setting keepRunning to false.");
+		//log.info("Main thread setting keepRunning to false.");
-		orderFetcher.stopSynch(); // Stops the FetchOrderUpdatesJobandAcknowledge thread.
+		//orderFetcher.stopSynch(); // Stops the FetchOrderUpdatesJobandAcknowledge thread.
 		// Join the two threads and wait for the fetchOrderUpdatesJobThread to
 		// finish.
-		try {
+		/*	try {
 			fetchOrderUpdatesJobThread.join();
 		} catch (InterruptedException e) {
 			log.error(e.getMessage(), e);
 			return;
-		}
+		}*/
+	}
 	/**
 	 * Call this method to start this job. Note that the job will run until the
 	 * keepRunning flag is set to false.
 		try {
 			df = DatatypeFactory.newInstance();
 		} catch (DatatypeConfigurationException e) {
 			log.error(e.getMessage(), e);
+		}
-		XMLGregorianCalendar startTime = df
+		// TODO - Get time from source details tables
-		//	.newXMLGregorianCalendar(new GregorianCalendar());
+		XMLGregorianCalendar startTime = df.newXMLGregorianCalendar(new GregorianCalendar());
-		.newXMLGregorianCalendar(new GregorianCalendar(2013,04,28,10,0));
+		XMLGregorianCalendar startTime = df.newXMLGregorianCalendar(new GregorianCalendar(2013,04,28,10,0));
 		// endTime = now -2. So, startTime = now - 2 - INTERVAL_IN_MINS.
 		System.out.println("Sync job start time." + startTime.getDay() +"-"+ startTime.getMonth()+"-" + startTime.getHour()+":"+startTime.getMinute());
-		startTime.add(df.newDurationDayTime(false, 0, 0, INTERVAL_IN_MINS ,
+		//startTime.add(df.newDurationDayTime(false, 0, 0, INTERVAL_IN_MINS ,	0));
-));
-		System.out.println("Sync job start time after add .." + startTime.getDay() +"-"+ startTime.getMonth()+"-" + startTime.getHour()+":"+startTime.getMinute());
+		//System.out.println("Sync job start time after add .." + startTime.getDay() +"-"+ startTime.getMonth()+"-" + startTime.getHour()+":"+startTime.getMinute());
 		/*
 		 * This loop keeps running until the stopSynch() method is called.
 		 * stopSynch() sets keepRunning to false.
 		 */
 		System.out.println("Sync job starting.");
 			 */
 			//if (timeWaited > 24 * 4 * INTERVAL_IN_MINS * 60L * 1000L) {
 			if (timeWaited > 100000 * 60L * 1000L) {
 				keepRunning = false;
 				System.out.println("Setting keep running to false");
-				log
-				.info("timeWaited is greater than 30 times the interval. This a too large a time interval for which to fetch orders.");
+				log.info("timeWaited is greater than 30 times the interval. This a too large a time interval for which to fetch orders.");
+			}
 			/*
 			 * If the time lapsed is greater than or equal to 15 mins, we will
 			 * try to fetchOrderUpdates giving it a startTime.
 			 */
 				XMLGregorianCalendar endTime = fetchOrderUpdatesSince(startTime);
 				//System.out.println("End Time is : " + endTime.getDay() +"-"+ endTime.getMonth()+"-" + endTime.getHour()+":"+endTime.getMinute());
 				//createandsubmitOrderAcknowlegementFeed();
 				if (endTime != null) {
 					startTime = endTime;
+					// TODO store end time in the database
 				} else {
 					log.info("endTime returned is null. Sleeping for "
 							+ INTERVAL_IN_MINS + " minutes.");
 					try {
 						Thread.sleep(INTERVAL_IN_MINS * 60L * 1000L);
 	 * it will terminate the job only after the call returns with valid results.
 	 * If this method is called while the thread is sleeping, because a request
 	 * was throttled, the job will terminate after it wakes up.
 	 */
 	public void stopSynch() {
-		keepRunning = false;
+		//keepRunning = false;
+	}
 	/**
 	 * Gets all orders updated between the given startTime and the calculated
 	 * endTime. The endTime is calculated by the service as server's system

Subversion Repositories SmartDukaan

(root)/trunk/AmazonOrders/src/main/java/com/amazonservices/mws/orders/samples/FetchOrderUpdatesJob.java – Rev 7512 → 7531