svn commit: r1848867 - /uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/transport/http/HttpServiceTransport.java

[cwiklik]

Author: cwiklik
Date: Thu Dec 13 16:56:54 2018
New Revision: 1848867

URL: http://svn.apache.org/viewvc?rev=1848867&view=rev
Log:
UIMA-5933 when throwing simulated errors optimized for..loop processing ERROR 
enums

Modified:
    
uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/transport/http/HttpServiceTransport.java

Modified: 
uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/transport/http/HttpServiceTransport.java
URL: 
http://svn.apache.org/viewvc/uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/transport/http/HttpServiceTransport.java?rev=1848867&r1=1848866&r2=1848867&view=diff
==============================================================================
--- 
uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/transport/http/HttpServiceTransport.java
 (original)
+++ 
uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/service/transport/http/HttpServiceTransport.java
 Thu Dec 13 16:56:54 2018
@@ -289,6 +289,7 @@ public class HttpServiceTransport implem
                        // NoHttpResponseException, 
                        // HttpHostConnectException, 
                        // URISyntaxException
+                       // Use JUnit test JunitTransoirtTestCase to test the 
above errors
                        
                        if ( ( simulatedException = 
System.getProperty("MockHttpPostError")) != null ) {
                                HttpClientExceptionGenerator 
mockExceptionGenerator = 
@@ -307,7 +308,6 @@ public class HttpServiceTransport implem
                                        log = false;
                                        stats.incrementErrorCount();
                                        logger.log(Level.WARNING, 
this.getClass().getName()+".dispatch() >>>>>>>>>> Handling Exception \n"+ex);
-//                                     System.out.println( 
this.getClass().getName()+".dispatch() >>>>>>>>>> Unable to communicate with 
target:"+currentTargetUrl.asString()+" - retrying until successfull - with 
"+threadSleepTime/1000+" seconds wait between retries  ");
                                        logger.log(Level.INFO, ">>>>>>>>>> 
Unable to communicate with target:"+currentTargetUrl.asString()+" - retrying 
until successfull - with "+threadSleepTime/1000+" seconds wait between retries  
");
                                }
                                serializedResponse = 
retryUntilSuccessfull(serializedRequest, postMethod);
@@ -359,9 +359,10 @@ public class HttpServiceTransport implem
        public static class HttpClientExceptionGenerator {
                public enum ERROR{ IOException, SocketException, 
UnknownHostException, NoRouteToHostException,NoHttpResponseException, 
HttpHostConnectException, URISyntaxException};
                
-               Exception exceptionClass;
+               Exception exceptionClass=null;
                
                public HttpClientExceptionGenerator(String exc) {
+                       
                        for( ERROR e : ERROR.values()) {
                                if ( exc != null && e.name().equals(exc)) {
                                        switch(e) {
@@ -388,6 +389,9 @@ public class HttpServiceTransport implem
                                                
                                                        
                                        }
+                                       if ( exceptionClass != null ) {
+                                               break;
+                                       }
                                }
                        }
                }