cxf-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dk...@apache.org
Subject svn commit: r1391652 - in /cxf/trunk: distribution/src/main/release/samples/ws-discovery/src/main/java/org/apache/cxf/samples/discovery/Client.java services/ws-discovery/ws-discovery-api/src/main/java/org/apache/cxf/ws/discovery/WSDiscoveryClient.java
Date Fri, 28 Sep 2012 20:54:19 GMT
Author: dkulp
Date: Fri Sep 28 20:54:19 2012
New Revision: 1391652

URL: http://svn.apache.org/viewvc?rev=1391652&view=rev
Log:
Ability to configure the probe timeout

Modified:
    cxf/trunk/distribution/src/main/release/samples/ws-discovery/src/main/java/org/apache/cxf/samples/discovery/Client.java
    cxf/trunk/services/ws-discovery/ws-discovery-api/src/main/java/org/apache/cxf/ws/discovery/WSDiscoveryClient.java

Modified: cxf/trunk/distribution/src/main/release/samples/ws-discovery/src/main/java/org/apache/cxf/samples/discovery/Client.java
URL: http://svn.apache.org/viewvc/cxf/trunk/distribution/src/main/release/samples/ws-discovery/src/main/java/org/apache/cxf/samples/discovery/Client.java?rev=1391652&r1=1391651&r2=1391652&view=diff
==============================================================================
--- cxf/trunk/distribution/src/main/release/samples/ws-discovery/src/main/java/org/apache/cxf/samples/discovery/Client.java
(original)
+++ cxf/trunk/distribution/src/main/release/samples/ws-discovery/src/main/java/org/apache/cxf/samples/discovery/Client.java
Fri Sep 28 20:54:19 2012
@@ -35,7 +35,7 @@ public final class Client {
 
     public static void main(String[] args) throws Exception {
 
-        //USe ws-discovery to find references to services that implement the Greeter portType
+        //Use WS-Discovery to find references to services that implement the Greeter portType
         WSDiscoveryClient client = new WSDiscoveryClient();
         List<EndpointReference> references 
             = client.probe(new QName("http://cxf.apache.org/hello_world/discovery", "Greeter"));

Modified: cxf/trunk/services/ws-discovery/ws-discovery-api/src/main/java/org/apache/cxf/ws/discovery/WSDiscoveryClient.java
URL: http://svn.apache.org/viewvc/cxf/trunk/services/ws-discovery/ws-discovery-api/src/main/java/org/apache/cxf/ws/discovery/WSDiscoveryClient.java?rev=1391652&r1=1391651&r2=1391652&view=diff
==============================================================================
--- cxf/trunk/services/ws-discovery/ws-discovery-api/src/main/java/org/apache/cxf/ws/discovery/WSDiscoveryClient.java
(original)
+++ cxf/trunk/services/ws-discovery/ws-discovery-api/src/main/java/org/apache/cxf/ws/discovery/WSDiscoveryClient.java
Fri Sep 28 20:54:19 2012
@@ -83,6 +83,7 @@ public class WSDiscoveryClient implement
     Dispatch<Object> dispatch;
     ObjectFactory factory = new ObjectFactory();
     Bus bus;
+    int defaultProbeTimeout = 1000;
     
     public WSDiscoveryClient() {
     }
@@ -93,6 +94,13 @@ public class WSDiscoveryClient implement
         resetDispatch(address);
     }
     
+    public void setDefaultProbeTimeout(int i) {
+        defaultProbeTimeout = i;
+    }
+    public int getDefaultProbeTimeout() {
+        return defaultProbeTimeout;
+    }
+    
     public String getAddress() {
         return address;
     }
@@ -244,7 +252,7 @@ public class WSDiscoveryClient implement
         if (type != null) {
             p.getTypes().add(type);
         }
-        ProbeMatchesType pmt = probe(p, 1000);
+        ProbeMatchesType pmt = probe(p, defaultProbeTimeout);
         List<EndpointReference> er = new ArrayList<EndpointReference>();
         for (ProbeMatchType pm : pmt.getProbeMatch()) {
             for (String add : pm.getXAddrs()) {
@@ -262,7 +270,7 @@ public class WSDiscoveryClient implement
     
     
     public ProbeMatchesType probe(ProbeType params) {
-        return probe(params, 1000);
+        return probe(params, defaultProbeTimeout);
     }    
     public ProbeMatchesType probe(ProbeType params, int timeout) {
         Dispatch<Object> disp = this.getDispatchInternal(false);
@@ -287,11 +295,9 @@ public class WSDiscoveryClient implement
                             }
                         }
                     } catch (InterruptedException e) {
-                        // TODO Auto-generated catch block
-                        e.printStackTrace();
+                        // ?
                     } catch (ExecutionException e) {
-                        // TODO Auto-generated catch block
-                        e.printStackTrace();
+                        // ?
                     }
                 }
             };



Mime
View raw message