Author: cmueller
Date: Mon Oct 15 20:39:53 2012
New Revision: 1398500

URL: http://svn.apache.org/viewvc?rev=1398500&view=rev
Log:
fixed issue with already assigned port numbers

Modified:
    
camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/BaseJettyTest.java

Modified: 
camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/BaseJettyTest.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/BaseJettyTest.java?rev=1398500&r1=1398499&r2=1398500&view=diff
==============================================================================
--- 
camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/BaseJettyTest.java
 (original)
+++ 
camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/BaseJettyTest.java
 Mon Oct 15 20:39:53 2012
@@ -17,6 +17,7 @@
 package org.apache.camel.component.jetty;
 
 import java.util.Properties;
+import java.util.concurrent.atomic.AtomicInteger;
 
 import org.apache.camel.CamelContext;
 import org.apache.camel.component.properties.PropertiesComponent;
@@ -28,6 +29,7 @@ import org.junit.BeforeClass;
 public abstract class BaseJettyTest extends CamelTestSupport {
 
     private static volatile int port;
+    private static final AtomicInteger counter = new AtomicInteger(1);
 
     @BeforeClass
     public static void initPort() throws Exception {
@@ -54,7 +56,7 @@ public abstract class BaseJettyTest exte
     }
 
     protected int getNextPort() {
-        return AvailablePortFinder.getNextAvailable(port + 1);
+        return AvailablePortFinder.getNextAvailable(port + 
counter.getAndIncrement());
     }
 
     protected int getNextPort(int startWithPort) {


Reply via email to