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) {