svn commit: r1836056 - /uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/sd/task/transport/HttpTaskTransportHandler.java

[burn]

Author: burn
Date: Mon Jul 16 17:22:35 2018
New Revision: 1836056

URL: http://svn.apache.org/viewvc?rev=1836056&view=rev
Log:
UIMA-5817 Find a free port if none specified

Modified:
    
uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/sd/task/transport/HttpTaskTransportHandler.java

Modified: 
uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/sd/task/transport/HttpTaskTransportHandler.java
URL: 
http://svn.apache.org/viewvc/uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/sd/task/transport/HttpTaskTransportHandler.java?rev=1836056&r1=1836055&r2=1836056&view=diff
==============================================================================
--- 
uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/sd/task/transport/HttpTaskTransportHandler.java
 (original)
+++ 
uima/uima-ducc/trunk/uima-ducc-pullservice/src/main/java/org/apache/uima/ducc/ps/sd/task/transport/HttpTaskTransportHandler.java
 Mon Jul 16 17:22:35 2018
@@ -144,12 +144,12 @@ public class HttpTaskTransportHandler im
        @Override
        public String initialize(Properties properties) throws 
TaskTransportException {
                // Max cores
-       int cores = Runtime.getRuntime().availableProcessors();
-       String maxThreadsString = (String) 
properties.get(ServiceDriver.MaxThreads);
-       String appName = (String) properties.get(ServiceDriver.Application);
+    int cores = Runtime.getRuntime().availableProcessors();
+    String maxThreadsString = (String) 
properties.get(ServiceDriver.MaxThreads);
+    String appName = (String) properties.get(ServiceDriver.Application);
 
                int maxThreads = cores;
-               int httpPort = -1;
+               int httpPort = 0;
                if (maxThreadsString != null) {
                        try {
                                maxThreads = 
Integer.parseInt(maxThreadsString.trim());
@@ -170,10 +170,9 @@ public class HttpTaskTransportHandler im
                                throw new TaskTransportException("Unable to 
start Server using provided port:"+httpPort);
                        }
                } 
-        if ( httpPort == 0 ) {
-                       // get ephemeral port for Jetty
-                       httpPort = findFreePort();
-               }
+    if (httpPort == 0) {     // Use any free port if none or 0 specified 
+      httpPort = findFreePort();
+    }
                if (appName == null) {
                  appName = "test";
                  logger.log(Level.WARNING, "The "+ServiceDriver.Application+" 
property is not specified - using "+appName);