You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ja...@apache.org on 2008/11/17 18:26:39 UTC
svn commit: r718279 -
/activemq/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/InterfacesTest.java
Author: janstey
Date: Mon Nov 17 09:26:38 2008
New Revision: 718279
URL: http://svn.apache.org/viewvc?rev=718279&view=rev
Log:
CAMEL-1091 - Fix compilation issue on Java 1.5
Modified:
activemq/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/InterfacesTest.java
Modified: activemq/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/InterfacesTest.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/InterfacesTest.java?rev=718279&r1=718278&r2=718279&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/InterfacesTest.java (original)
+++ activemq/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/InterfacesTest.java Mon Nov 17 09:26:38 2008
@@ -15,25 +15,27 @@
private String remoteInterfaceAddress;
- public InterfacesTest() throws SocketException {
- // retirieve an address of some remote network interface
+ public InterfacesTest() throws IOException {
+ // Retrieve an address of some remote network interface
Enumeration<NetworkInterface> interfaces = NetworkInterface.getNetworkInterfaces();
while(interfaces.hasMoreElements()) {
NetworkInterface interfaze = interfaces.nextElement();
- if (!interfaze.isUp() || interfaze.isLoopback()) {
- continue;
- }
Enumeration<InetAddress> addresses = interfaze.getInetAddresses();
- if(addresses.hasMoreElements()) {
- remoteInterfaceAddress = addresses.nextElement().getHostAddress();
+ if(addresses.hasMoreElements()) {
+ InetAddress nextAddress = addresses.nextElement();
+ if (nextAddress.isLoopbackAddress() || nextAddress.isReachable(2000)) {
+ break;
+ }
+ remoteInterfaceAddress = nextAddress.getHostAddress();
}
};
}
public void testLocalInterfaceHandled() throws IOException, InterruptedException {
- getMockEndpoint("mock:endpoint").expectedMessageCount(3);
+ int expectedMessages = (remoteInterfaceAddress != null) ? 3 : 2;
+ getMockEndpoint("mock:endpoint").expectedMessageCount(expectedMessages);
URL localUrl = new URL("http://localhost:4567/testRoute");
String localResponse = IOUtils.toString(localUrl.openStream());
@@ -44,9 +46,11 @@
localResponse = IOUtils.toString(localUrl.openStream());
assertEquals("local-differentPort", localResponse);
- URL url = new URL("http://" + remoteInterfaceAddress + ":4567/testRoute");
- String remoteResponse = IOUtils.toString(url.openStream());
- assertEquals("remote", remoteResponse);
+ if (remoteInterfaceAddress != null) {
+ URL url = new URL("http://" + remoteInterfaceAddress + ":4567/testRoute");
+ String remoteResponse = IOUtils.toString(url.openStream());
+ assertEquals("remote", remoteResponse);
+ }
assertMockEndpointsSatisfied();
}
@@ -65,9 +69,11 @@
.setBody().constant("local-differentPort")
.to("mock:endpoint");
- from("jetty:http://" + remoteInterfaceAddress + ":4567/testRoute")
- .setBody().constant("remote")
- .to("mock:endpoint");
+ if (remoteInterfaceAddress != null) {
+ from("jetty:http://" + remoteInterfaceAddress + ":4567/testRoute")
+ .setBody().constant("remote")
+ .to("mock:endpoint");
+ }
}
};
}