From 2e53441d0777a179cde24288451555fdf0b70e23 Mon Sep 17 00:00:00 2001 From: nash Date: Thu, 4 Feb 2010 08:24:53 +0000 Subject: Launch JMS broker and CORBA tnameserv automatically (TUSCANY-3454) git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@906398 13f79535-47bb-0310-9956-ffa450edef68 --- .../services/smsgateway-corba/build.xml | 9 --- .../SMSGatewayCORBAServiceBootstrap.java | 89 ++++++++++++++++------ .../travelsample/services/smsgateway-jms/build.xml | 12 --- .../src/main/java/scatours/JMSBrokerLauncher.java | 38 --------- .../smsgateway/SMSGatewayJMSServiceBootstrap.java | 7 ++ 5 files changed, 73 insertions(+), 82 deletions(-) delete mode 100644 sca-java-1.x/trunk/tutorials/travelsample/services/smsgateway-jms/src/main/java/scatours/JMSBrokerLauncher.java (limited to 'sca-java-1.x/trunk/tutorials/travelsample/services') diff --git a/sca-java-1.x/trunk/tutorials/travelsample/services/smsgateway-corba/build.xml b/sca-java-1.x/trunk/tutorials/travelsample/services/smsgateway-corba/build.xml index c0bd7e24a4..cfba0cea3d 100644 --- a/sca-java-1.x/trunk/tutorials/travelsample/services/smsgateway-corba/build.xml +++ b/sca-java-1.x/trunk/tutorials/travelsample/services/smsgateway-corba/build.xml @@ -28,15 +28,6 @@ - - - - - - - - diff --git a/sca-java-1.x/trunk/tutorials/travelsample/services/smsgateway-corba/src/main/java/scatours/smsgateway/SMSGatewayCORBAServiceBootstrap.java b/sca-java-1.x/trunk/tutorials/travelsample/services/smsgateway-corba/src/main/java/scatours/smsgateway/SMSGatewayCORBAServiceBootstrap.java index 3ea7f7de44..9a53303e88 100644 --- a/sca-java-1.x/trunk/tutorials/travelsample/services/smsgateway-corba/src/main/java/scatours/smsgateway/SMSGatewayCORBAServiceBootstrap.java +++ b/sca-java-1.x/trunk/tutorials/travelsample/services/smsgateway-corba/src/main/java/scatours/smsgateway/SMSGatewayCORBAServiceBootstrap.java @@ -18,6 +18,10 @@ */ package scatours.smsgateway; +import java.io.BufferedReader; +import java.io.InputStream; +import java.io.InputStreamReader; + import org.omg.CORBA.ORB; import org.omg.CORBA.Object; import org.omg.CosNaming.NameComponent; @@ -29,34 +33,73 @@ import org.omg.PortableServer.POAHelper; public class SMSGatewayCORBAServiceBootstrap { public static void main(String[] args) throws Exception { - System.out.println("Publishing SMS Gateway Service as a CORBA service: SMSGatewayCORBAService (port=5080)"); - - String[] orbArgs = {"-ORBInitialPort", "5080"}; - ORB orb = ORB.init(orbArgs, null); + String home = System.getProperty("java.home"); + String[] tnsCommand = {"" + home + "/bin/tnameserv", "-ORBInitialPort", "5080"}; + Process tns = null; - NamingContextExt namingCtx; try { - Object objRef = orb.resolve_initial_references("NameService"); - namingCtx = NamingContextExtHelper.narrow(objRef); - } catch (Exception ex) { - System.err.println("ERROR: Failed to resolve Name Service."); - System.err.println("Don't forget to run it with:"); - System.err.println(" tnameserv -ORBInitialPort 5080"); - return; - } + System.out.println("Starting transient name server process (port=5080)"); + + // Start tnameserv in a separate process + tns = Runtime.getRuntime().exec(tnsCommand); + + // Wait for the tnameserv process to complete its startup, and + // display the output from the tnameserv process on the console + InputStream tnsOut = tns.getInputStream(); + BufferedReader tnsOutReader = new BufferedReader(new InputStreamReader(tnsOut)); + while (true) { + String line = tnsOutReader.readLine(); + System.out.println("tnameserv: " + line); + if ("Ready.".equals(line)) { + break; + } + } + + System.out.println("Publishing SMS Gateway Service as a CORBA service: SMSGatewayCORBAService (port=5080)"); - Object rootPoaRef = orb.resolve_initial_references("RootPOA"); - POA rootPoa = POAHelper.narrow(rootPoaRef); - rootPoa.the_POAManager().activate(); + String[] orbArgs = {"-ORBInitialPort", "5080"}; + ORB orb = ORB.init(orbArgs, null); - SMSGatewayServant smsGateway = new SMSGatewayServant(); - Object smsGatewayRef = rootPoa.servant_to_reference(smsGateway); + NamingContextExt namingCtx; + try { + Object objRef = orb.resolve_initial_references("NameService"); + namingCtx = NamingContextExtHelper.narrow(objRef); + } catch (Exception ex) { + System.err.println("ERROR: Failed to resolve Name Service."); + //System.err.println("Don't forget to run it with:"); + //System.err.println(" tnameserv -ORBInitialPort 5080"); + return; + } - String corbaServerName = "SMSGatewayCORBAService"; - NameComponent[] name = {new NameComponent(corbaServerName, "")}; - namingCtx.rebind(name, smsGatewayRef); + Object rootPoaRef = orb.resolve_initial_references("RootPOA"); + POA rootPoa = POAHelper.narrow(rootPoaRef); + rootPoa.the_POAManager().activate(); - System.out.println("CORBA server running - waiting for requests"); - orb.run(); + SMSGatewayServant smsGateway = new SMSGatewayServant(); + Object smsGatewayRef = rootPoa.servant_to_reference(smsGateway); + + String corbaServerName = "SMSGatewayCORBAService"; + NameComponent[] name = {new NameComponent(corbaServerName, "")}; + namingCtx.rebind(name, smsGatewayRef); + + System.out.println("CORBA server running - press Enter to shutdown"); + System.in.read(); + + orb.shutdown(true); + orb.destroy(); + + } finally { + // Make sure that the tnameserv process gets destroyed and its + // listener port is released + if (tns != null) { + System.out.println("Destroying transient name server process"); + try { + tns.destroy(); + System.out.println("Transient name server process destroyed"); + } catch (Exception e) { + // ignore + } + } + } } } diff --git a/sca-java-1.x/trunk/tutorials/travelsample/services/smsgateway-jms/build.xml b/sca-java-1.x/trunk/tutorials/travelsample/services/smsgateway-jms/build.xml index fe7e66111e..389f6296c3 100644 --- a/sca-java-1.x/trunk/tutorials/travelsample/services/smsgateway-jms/build.xml +++ b/sca-java-1.x/trunk/tutorials/travelsample/services/smsgateway-jms/build.xml @@ -20,18 +20,6 @@ - - - - - - - - - - - diff --git a/sca-java-1.x/trunk/tutorials/travelsample/services/smsgateway-jms/src/main/java/scatours/JMSBrokerLauncher.java b/sca-java-1.x/trunk/tutorials/travelsample/services/smsgateway-jms/src/main/java/scatours/JMSBrokerLauncher.java deleted file mode 100644 index 929eb78431..0000000000 --- a/sca-java-1.x/trunk/tutorials/travelsample/services/smsgateway-jms/src/main/java/scatours/JMSBrokerLauncher.java +++ /dev/null @@ -1,38 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ -package scatours; - -import org.apache.activemq.broker.BrokerService; - -public class JMSBrokerLauncher { - - public static void main(String[] args) throws Exception { - final BrokerService jmsBroker = new BrokerService(); - jmsBroker.setPersistent(false); - jmsBroker.setUseJmx(false); - jmsBroker.addConnector("tcp://localhost:61619"); - jmsBroker.start(); - - System.out.println("JMS Message Broker started"); - System.out.println("Press enter to shutdown."); - System.in.read(); - - jmsBroker.stop(); - } -} diff --git a/sca-java-1.x/trunk/tutorials/travelsample/services/smsgateway-jms/src/main/java/scatours/smsgateway/SMSGatewayJMSServiceBootstrap.java b/sca-java-1.x/trunk/tutorials/travelsample/services/smsgateway-jms/src/main/java/scatours/smsgateway/SMSGatewayJMSServiceBootstrap.java index b4effa6f82..d8543266e3 100644 --- a/sca-java-1.x/trunk/tutorials/travelsample/services/smsgateway-jms/src/main/java/scatours/smsgateway/SMSGatewayJMSServiceBootstrap.java +++ b/sca-java-1.x/trunk/tutorials/travelsample/services/smsgateway-jms/src/main/java/scatours/smsgateway/SMSGatewayJMSServiceBootstrap.java @@ -22,10 +22,17 @@ import javax.jms.Connection; import javax.jms.Session; import org.apache.activemq.ActiveMQConnectionFactory; +import org.apache.activemq.broker.BrokerService; public class SMSGatewayJMSServiceBootstrap { public static void main(String[] args) throws Exception { + final BrokerService jmsBroker = new BrokerService(); + jmsBroker.setPersistent(false); + jmsBroker.setUseJmx(false); + jmsBroker.addConnector("tcp://localhost:61619"); + jmsBroker.start(); + System.out.println("Publishing SMS Gateway Service as a JMS service: tcp://localhost:61619"); System.out.println("Press Ctrl^C to terminate..."); -- cgit v1.2.3