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:28:52 UTC
svn commit: r1304370 - in /cxf/trunk/distribution/src/main/release/samples:
jms_pubsub/src/main/java/demo/jms_greeter/server/Server.java
jms_queue/src/main/java/demo/jms_greeter/server/Server.java
Author: dkulp
Date: Fri Mar 23 14:28:51 2012
New Revision: 1304370
URL: http://svn.apache.org/viewvc?rev=1304370&view=rev
Log:
Make sure the endpoints are stopped for the jms servers so that the
connections to the broker can cleanly disconnect without errors.
Modified:
cxf/trunk/distribution/src/main/release/samples/jms_pubsub/src/main/java/demo/jms_greeter/server/Server.java
cxf/trunk/distribution/src/main/release/samples/jms_queue/src/main/java/demo/jms_greeter/server/Server.java
Modified: cxf/trunk/distribution/src/main/release/samples/jms_pubsub/src/main/java/demo/jms_greeter/server/Server.java
URL: http://svn.apache.org/viewvc/cxf/trunk/distribution/src/main/release/samples/jms_pubsub/src/main/java/demo/jms_greeter/server/Server.java?rev=1304370&r1=1304369&r2=1304370&view=diff
==============================================================================
--- cxf/trunk/distribution/src/main/release/samples/jms_pubsub/src/main/java/demo/jms_greeter/server/Server.java (original)
+++ cxf/trunk/distribution/src/main/release/samples/jms_pubsub/src/main/java/demo/jms_greeter/server/Server.java Fri Mar 23 14:28:51 2012
@@ -22,20 +22,35 @@ package demo.jms_greeter.server;
import javax.xml.ws.Endpoint;
public class Server {
+ Endpoint ep;
protected Server() throws Exception {
System.out.println("Starting Server");
Object implementor = new GreeterJMSImpl();
String address = "http://cxf.apache.org/transports/jms";
- Endpoint.publish(address, implementor);
+ ep = Endpoint.publish(address, implementor);
+
+ Runtime.getRuntime().addShutdownHook(new Thread() {
+ public void run() {
+ shutdown();
+ }
+ });
+ }
+ public void shutdown() {
+ if (ep != null) {
+ ep.stop();
+ ep = null;
+ }
}
public static void main(String args[]) throws Exception {
- new Server();
+ Server s = new Server();
System.out.println("Server ready...");
-
- Thread.sleep(125 * 60 * 1000);
- System.out.println("Server exiting");
- System.exit(0);
+ try {
+ Thread.sleep(5 * 60 * 1000);
+ System.out.println("Server exiting");
+ } finally {
+ s.shutdown();
+ }
}
}
Modified: cxf/trunk/distribution/src/main/release/samples/jms_queue/src/main/java/demo/jms_greeter/server/Server.java
URL: http://svn.apache.org/viewvc/cxf/trunk/distribution/src/main/release/samples/jms_queue/src/main/java/demo/jms_greeter/server/Server.java?rev=1304370&r1=1304369&r2=1304370&view=diff
==============================================================================
--- cxf/trunk/distribution/src/main/release/samples/jms_queue/src/main/java/demo/jms_greeter/server/Server.java (original)
+++ cxf/trunk/distribution/src/main/release/samples/jms_queue/src/main/java/demo/jms_greeter/server/Server.java Fri Mar 23 14:28:51 2012
@@ -22,20 +22,36 @@ package demo.jms_greeter.server;
import javax.xml.ws.Endpoint;
public class Server {
+ Endpoint ep;
protected Server() throws Exception {
System.out.println("Starting Server");
Object implementor = new GreeterJMSImpl();
String address = "http://cxf.apache.org/transports/jms";
- Endpoint.publish(address, implementor);
+ ep = Endpoint.publish(address, implementor);
+
+ Runtime.getRuntime().addShutdownHook(new Thread() {
+ public void run() {
+ shutdown();
+ }
+ });
+ }
+
+ public void shutdown() {
+ if (ep != null) {
+ ep.stop();
+ ep = null;
+ }
}
public static void main(String args[]) throws Exception {
- new Server();
+ Server s = new Server();
System.out.println("Server ready...");
-
- Thread.sleep(125 * 60 * 1000);
- System.out.println("Server exiting");
- System.exit(0);
+ try {
+ Thread.sleep(5 * 60 * 1000);
+ System.out.println("Server exiting");
+ } finally {
+ s.shutdown();
+ }
}
}