- Adding multi threading test.

srathod · srathod · commit 3948f2576df6 · 2016-10-03T18:29:42.000+05:30
diff --git a/src/main/java/net/authorize/sample/TestMultiThread.java b/src/main/java/net/authorize/sample/TestMultiThread.java
@@ -0,0 +1,101 @@
+package net.authorize.sample;
+
+import java.security.SecureRandom;
+import java.text.DecimalFormat;
+import java.util.Date;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+import net.authorize.api.contract.v1.CreateCustomerPaymentProfileResponse;
+import net.authorize.api.contract.v1.CreateCustomerProfileResponse;
+import net.authorize.api.contract.v1.CreateTransactionResponse;
+import net.authorize.sample.CustomerProfiles.CreateCustomerPaymentProfile;
+import net.authorize.sample.CustomerProfiles.CreateCustomerProfile;
+import net.authorize.sample.PaymentTransactions.ChargeCustomerProfile;
+
+public class TestMultiThread {
+
+	private static final int MYTHREADS = 120;
+	private static String apiLoginId           = "5KP3u95bQpv";
+	private static String transactionKey       = "346HZ32z3fP4hTG2";
+	
+	static SecureRandom rgenerator = new SecureRandom();
+	
+	private static Double getAmount()
+	{
+		double d = (double)(1.05 + (450.0 * rgenerator.nextDouble()));
+		DecimalFormat df = new DecimalFormat("#.##");      
+		d = Double.valueOf(df.format(d));
+		return d;
+	}
+	
+	private static String getEmail()
+	{
+		return rgenerator.nextInt(10000) + "@test.com";
+	}
+	 
+	public static void main(String args[]) throws Exception {
+		ExecutorService executor = Executors.newFixedThreadPool(MYTHREADS);
+ 
+		Date dt1 = new Date();
+		for (int i = 0; i < MYTHREADS; i++) {
+			Runnable worker = new MyRunnable();
+			executor.execute(worker);
+		}
+		executor.shutdown();
+		
+		// Wait until all threads are finish
+		while (!executor.isTerminated()) {
+ 
+		}
+		Date dt2 = new Date();
+		long difference = dt2.getTime() - dt1.getTime();
+
+		System.out.println("\nFinished all threads : " +  difference/1000 + " sec");
+	}
+ 
+	public static class MyRunnable implements Runnable {
+
+		@Override
+		public void run() {
+			CreateCustomerProfileResponse response = null;
+			CreateCustomerPaymentProfileResponse paymentProfileResponse = null;
+
+			try{
+				response = (CreateCustomerProfileResponse)CreateCustomerProfile.run(apiLoginId, transactionKey, getEmail());
+				paymentProfileResponse = (CreateCustomerPaymentProfileResponse)CreateCustomerPaymentProfile.run(apiLoginId, transactionKey, response.getCustomerProfileId());
+			}
+			catch (Exception e) {
+				System.out.println("Failure in CIM calls.");
+				System.out.println(e.getMessage());
+				return;
+			}
+		
+			try {
+				Date dt1 = new Date();
+				System.out.println("============================================================================");
+				System.out.println("chargeResponse Dt1: + " + dt1.toString());
+				
+				if((response.getCustomerProfileId() != null) && (paymentProfileResponse.getCustomerPaymentProfileId() != null))
+				{
+					CreateTransactionResponse chargeResponse = (CreateTransactionResponse) ChargeCustomerProfile.run(apiLoginId, transactionKey,
+							response.getCustomerProfileId(), paymentProfileResponse.getCustomerPaymentProfileId(), getAmount());
+				}
+				else
+				{
+					System.out.println("NULL PROFILE IDS.");
+				}
+				
+				Date dt2 = new Date();
+				System.out.println("chargeResponse Dt2: + " + dt2.toString());
+				
+				long difference = dt2.getTime() - dt1.getTime();
+				System.out.println("chargeResponse Diff: " + difference/1000);
+				System.out.println("============================================================================");
+			} catch (Exception e) {
+				System.out.println("Failure in charge customer profile call:");
+				System.out.println(e.getMessage());
+			}
+		}
+	}
+}
