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 2012/03/23 15:33:47 UTC
svn commit: r1304373 - in /cxf/trunk/distribution/src/main/release/samples:
ws_rm/src/main/java/demo/ws_rm/client/
ws_security/sign_enc/src/main/java/demo/wssec/client/
ws_security/ut/src/demo/wssec/client/
ws_security/ut_sign/src/main/java/demo/wssec/...
Author: dkulp
Date: Fri Mar 23 14:33:47 2012
New Revision: 1304373
URL: http://svn.apache.org/viewvc?rev=1304373&view=rev
Log:
Close the proxies so the decoupled endpoints can cleanly shutdown
Modified:
cxf/trunk/distribution/src/main/release/samples/ws_rm/src/main/java/demo/ws_rm/client/Client.java
cxf/trunk/distribution/src/main/release/samples/ws_security/sign_enc/src/main/java/demo/wssec/client/Client.java
cxf/trunk/distribution/src/main/release/samples/ws_security/ut/src/demo/wssec/client/Client.java
cxf/trunk/distribution/src/main/release/samples/ws_security/ut_sign/src/main/java/demo/wssec/client/Client.java
Modified: cxf/trunk/distribution/src/main/release/samples/ws_rm/src/main/java/demo/ws_rm/client/Client.java
URL: http://svn.apache.org/viewvc/cxf/trunk/distribution/src/main/release/samples/ws_rm/src/main/java/demo/ws_rm/client/Client.java?rev=1304373&r1=1304372&r2=1304373&view=diff
==============================================================================
--- cxf/trunk/distribution/src/main/release/samples/ws_rm/src/main/java/demo/ws_rm/client/Client.java (original)
+++ cxf/trunk/distribution/src/main/release/samples/ws_rm/src/main/java/demo/ws_rm/client/Client.java Fri Mar 23 14:33:47 2012
@@ -19,6 +19,7 @@
package demo.ws_rm.client;
+import java.io.Closeable;
import java.io.File;
import java.lang.reflect.UndeclaredThrowableException;
import java.net.URL;
@@ -75,6 +76,9 @@ public final class Client {
// allow aynchronous resends to occur
Thread.sleep(30 * 1000);
+ if (port instanceof Closeable) {
+ ((Closeable)port).close();
+ }
bus.shutdown(true);
} catch (UndeclaredThrowableException ex) {
Modified: cxf/trunk/distribution/src/main/release/samples/ws_security/sign_enc/src/main/java/demo/wssec/client/Client.java
URL: http://svn.apache.org/viewvc/cxf/trunk/distribution/src/main/release/samples/ws_security/sign_enc/src/main/java/demo/wssec/client/Client.java?rev=1304373&r1=1304372&r2=1304373&view=diff
==============================================================================
--- cxf/trunk/distribution/src/main/release/samples/ws_security/sign_enc/src/main/java/demo/wssec/client/Client.java (original)
+++ cxf/trunk/distribution/src/main/release/samples/ws_security/sign_enc/src/main/java/demo/wssec/client/Client.java Fri Mar 23 14:33:47 2012
@@ -19,6 +19,8 @@
package demo.wssec.client;
+import java.io.Closeable;
+
import java.lang.reflect.UndeclaredThrowableException;
import java.net.URL;
import java.util.HashMap;
@@ -107,6 +109,10 @@ public final class Client {
// allow aynchronous resends to occur
Thread.sleep(30 * 1000);
+ if (port instanceof Closeable) {
+ ((Closeable)port).close();
+ }
+
bus.shutdown(true);
} catch (UndeclaredThrowableException ex) {
Modified: cxf/trunk/distribution/src/main/release/samples/ws_security/ut/src/demo/wssec/client/Client.java
URL: http://svn.apache.org/viewvc/cxf/trunk/distribution/src/main/release/samples/ws_security/ut/src/demo/wssec/client/Client.java?rev=1304373&r1=1304372&r2=1304373&view=diff
==============================================================================
--- cxf/trunk/distribution/src/main/release/samples/ws_security/ut/src/demo/wssec/client/Client.java (original)
+++ cxf/trunk/distribution/src/main/release/samples/ws_security/ut/src/demo/wssec/client/Client.java Fri Mar 23 14:33:47 2012
@@ -19,6 +19,7 @@
package demo.wssec.client;
+import java.io.Closeable;
import java.lang.reflect.UndeclaredThrowableException;
import java.net.URL;
import java.util.HashMap;
@@ -77,6 +78,9 @@ public final class Client {
System.out.println("response: " + response + "\n");
}
+ if (port instanceof Closeable) {
+ ((Closeable)port).close();
+ }
bus.shutdown(true);
Modified: cxf/trunk/distribution/src/main/release/samples/ws_security/ut_sign/src/main/java/demo/wssec/client/Client.java
URL: http://svn.apache.org/viewvc/cxf/trunk/distribution/src/main/release/samples/ws_security/ut_sign/src/main/java/demo/wssec/client/Client.java?rev=1304373&r1=1304372&r2=1304373&view=diff
==============================================================================
--- cxf/trunk/distribution/src/main/release/samples/ws_security/ut_sign/src/main/java/demo/wssec/client/Client.java (original)
+++ cxf/trunk/distribution/src/main/release/samples/ws_security/ut_sign/src/main/java/demo/wssec/client/Client.java Fri Mar 23 14:33:47 2012
@@ -19,6 +19,7 @@
package demo.wssec.client;
+import java.io.Closeable;
import java.lang.reflect.UndeclaredThrowableException;
import java.net.URL;
import java.util.HashMap;
@@ -91,6 +92,10 @@ public final class Client {
String response = port.greetMe(names[i]);
System.out.println("response: " + response + "\n");
}
+
+ if (port instanceof Closeable) {
+ ((Closeable)port).close();
+ }
bus.shutdown(true);