You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cxf.apache.org by dk...@apache.org on 2013/08/29 19:54:38 UTC
svn commit: r1518730 -
/cxf/branches/2.6.x-fixes/testutils/src/main/java/org/apache/cxf/testutil/common/EmbeddedJMSBrokerLauncher.java
Author: dkulp
Date: Thu Aug 29 17:54:37 2013
New Revision: 1518730
URL: http://svn.apache.org/r1518730
Log:
Fix broken compile
Modified:
cxf/branches/2.6.x-fixes/testutils/src/main/java/org/apache/cxf/testutil/common/EmbeddedJMSBrokerLauncher.java
Modified: cxf/branches/2.6.x-fixes/testutils/src/main/java/org/apache/cxf/testutil/common/EmbeddedJMSBrokerLauncher.java
URL: http://svn.apache.org/viewvc/cxf/branches/2.6.x-fixes/testutils/src/main/java/org/apache/cxf/testutil/common/EmbeddedJMSBrokerLauncher.java?rev=1518730&r1=1518729&r2=1518730&view=diff
==============================================================================
--- cxf/branches/2.6.x-fixes/testutils/src/main/java/org/apache/cxf/testutil/common/EmbeddedJMSBrokerLauncher.java (original)
+++ cxf/branches/2.6.x-fixes/testutils/src/main/java/org/apache/cxf/testutil/common/EmbeddedJMSBrokerLauncher.java Thu Aug 29 17:54:37 2013
@@ -32,6 +32,7 @@ import org.apache.activemq.broker.Broker
import org.apache.activemq.store.memory.MemoryPersistenceAdapter;
import org.apache.cxf.Bus;
import org.apache.cxf.BusFactory;
+import org.apache.cxf.common.util.ReflectionUtil;
import org.apache.cxf.wsdl.WSDLManager;
public class EmbeddedJMSBrokerLauncher extends AbstractBusTestServerBase {
@@ -75,13 +76,13 @@ public class EmbeddedJMSBrokerLauncher e
for (Object o : map.values()) {
Service service = (Service)o;
Map<?, ?> ports = service.getPorts();
- adjustExtensibilityElements(service.getExtensibilityElements(), url, encodedUrl);
+ adjustExtensibilityElements(service.getExtensibilityElements(), url);
for (Object p : ports.values()) {
Port port = (Port)p;
- adjustExtensibilityElements(port.getExtensibilityElements(), url, encodedUrl);
- adjustExtensibilityElements(port.getBinding().getExtensibilityElements(), url, encodedUrl);
+ adjustExtensibilityElements(port.getExtensibilityElements(), url);
+ adjustExtensibilityElements(port.getBinding().getExtensibilityElements(), url);
}
}
} catch (Exception e) {
@@ -90,8 +91,7 @@ public class EmbeddedJMSBrokerLauncher e
}
private static void adjustExtensibilityElements(List<?> l,
- String url,
- String encodedUrl) {
+ String url) {
for (Object e : l) {
if (e instanceof SOAPAddress) {
String add = ((SOAPAddress)e).getLocationURI();
@@ -99,7 +99,7 @@ public class EmbeddedJMSBrokerLauncher e
if (idx != -1) {
int idx2 = add.indexOf("&", idx);
add = add.substring(0, idx)
- + "jndiURL=" + encodedUrl
+ + "jndiURL=" + url
+ (idx2 == -1 ? "" : add.substring(idx2));
((SOAPAddress)e).setLocationURI(add);
}