X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fmr%2Ftest%2Fclients%2FSimpleExampleConsumerWithReturnResponse.java;fp=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fmr%2Ftest%2Fclients%2FSimpleExampleConsumerWithReturnResponse.java;h=f7341ecc9a4504ed54b4b8f2f7bd98c9de149b00;hb=78ebc9a64fac6231e3e594200b9335a4c6372ed1;hp=2e514b0b59bf81c244483b6e2ab5b48ba662e614;hpb=8a00d4324ea7621df1a1febb8936df2807cbc443;p=dmaap%2Fmessagerouter%2Fdmaapclient.git

diff --git a/src/main/java/org/onap/dmaap/mr/test/clients/SimpleExampleConsumerWithReturnResponse.java b/src/main/java/org/onap/dmaap/mr/test/clients/SimpleExampleConsumerWithReturnResponse.java
index 2e514b0..f7341ec 100644
--- a/src/main/java/org/onap/dmaap/mr/test/clients/SimpleExampleConsumerWithReturnResponse.java
+++ b/src/main/java/org/onap/dmaap/mr/test/clients/SimpleExampleConsumerWithReturnResponse.java
@@ -45,6 +45,9 @@ public class SimpleExampleConsumerWithReturnResponse {
 	
 		long count = 0;
 		long nextReport = 5000;
+		// remove while true and limite execution time in seconds
+		int timeMax = 86400; // one day
+		long endDate = System.currentTimeMillis() + timeMax*1000;
 
 		final long startMs = System.currentTimeMillis ();
 				
@@ -60,7 +63,7 @@ public class SimpleExampleConsumerWithReturnResponse {
 			routeReader= new FileReader(new File (routeFilePath));
 			props= new Properties();
 			final MRConsumer cc = MRClientFactory.createConsumer ( "src/main/resources/dme2/consumer.properties" );
-			while ( true )
+			while ( System.currentTimeMillis() < endDate )
 			{	
 				MRConsumerResponse mrConsumerResponse = cc.fetchWithReturnConsumerResponse();
 				System.out.println("mrConsumerResponse code :"+mrConsumerResponse.getResponseCode());