From 98eec492c08e491401841dd33e8392b41c1e6660 Mon Sep 17 00:00:00 2001 From: nash Date: Thu, 10 Jun 2010 20:27:31 +0000 Subject: Copy travelsample-1.0-RC3 tag as travelsample-1.0 git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@953445 13f79535-47bb-0310-9956-ffa450edef68 --- .../services/smsgateway-corba/build.xml | 37 ++++++++ .../services/smsgateway-corba/pom.xml | 76 +++++++++++++++ .../SMSGatewayCORBAServiceBootstrap.java | 105 +++++++++++++++++++++ .../scatours/smsgateway/SMSGatewayServant.java | 30 ++++++ .../src/main/resources/sms-gateway.idl | 26 +++++ 5 files changed, 274 insertions(+) create mode 100644 sca-java-1.x/tags/travelsample-1.0/services/smsgateway-corba/build.xml create mode 100644 sca-java-1.x/tags/travelsample-1.0/services/smsgateway-corba/pom.xml create mode 100644 sca-java-1.x/tags/travelsample-1.0/services/smsgateway-corba/src/main/java/scatours/smsgateway/SMSGatewayCORBAServiceBootstrap.java create mode 100644 sca-java-1.x/tags/travelsample-1.0/services/smsgateway-corba/src/main/java/scatours/smsgateway/SMSGatewayServant.java create mode 100644 sca-java-1.x/tags/travelsample-1.0/services/smsgateway-corba/src/main/resources/sms-gateway.idl (limited to 'sca-java-1.x/tags/travelsample-1.0/services/smsgateway-corba') diff --git a/sca-java-1.x/tags/travelsample-1.0/services/smsgateway-corba/build.xml b/sca-java-1.x/tags/travelsample-1.0/services/smsgateway-corba/build.xml new file mode 100644 index 0000000000..0495e2b956 --- /dev/null +++ b/sca-java-1.x/tags/travelsample-1.0/services/smsgateway-corba/build.xml @@ -0,0 +1,37 @@ + + + + + + + + + + + + + + + + + + + diff --git a/sca-java-1.x/tags/travelsample-1.0/services/smsgateway-corba/pom.xml b/sca-java-1.x/tags/travelsample-1.0/services/smsgateway-corba/pom.xml new file mode 100644 index 0000000000..36e70fff1f --- /dev/null +++ b/sca-java-1.x/tags/travelsample-1.0/services/smsgateway-corba/pom.xml @@ -0,0 +1,76 @@ + + + + 4.0.0 + + org.apache.tuscany.sca + scatours + 1.0 + ../../pom.xml + + scatours-service-smsgateway-corba + Apache Tuscany SCA Tours SMS Gateway CORBA Service + + + ${artifactId} + + + org.apache.maven.plugins + maven-jar-plugin + 2.2 + + + + ${scatours.selfContained} + ../lib/ + scatours.smsgateway.SMSGatewayCORBAServiceBootstrap + + + + + + org.codehaus.mojo + idlj-maven-plugin + 1.1 + + + + generate + + + + + idlj + + + + sms-gateway.idl + + true + true + false + + + ${basedir}/src/main/resources + + + + + diff --git a/sca-java-1.x/tags/travelsample-1.0/services/smsgateway-corba/src/main/java/scatours/smsgateway/SMSGatewayCORBAServiceBootstrap.java b/sca-java-1.x/tags/travelsample-1.0/services/smsgateway-corba/src/main/java/scatours/smsgateway/SMSGatewayCORBAServiceBootstrap.java new file mode 100644 index 0000000000..9a53303e88 --- /dev/null +++ b/sca-java-1.x/tags/travelsample-1.0/services/smsgateway-corba/src/main/java/scatours/smsgateway/SMSGatewayCORBAServiceBootstrap.java @@ -0,0 +1,105 @@ +/* + * 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.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; +import org.omg.CosNaming.NamingContextExt; +import org.omg.CosNaming.NamingContextExtHelper; +import org.omg.PortableServer.POA; +import org.omg.PortableServer.POAHelper; + +public class SMSGatewayCORBAServiceBootstrap { + + public static void main(String[] args) throws Exception { + String home = System.getProperty("java.home"); + String[] tnsCommand = {"" + home + "/bin/tnameserv", "-ORBInitialPort", "5080"}; + Process tns = null; + + try { + 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)"); + + String[] orbArgs = {"-ORBInitialPort", "5080"}; + ORB orb = ORB.init(orbArgs, 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; + } + + Object rootPoaRef = orb.resolve_initial_references("RootPOA"); + POA rootPoa = POAHelper.narrow(rootPoaRef); + rootPoa.the_POAManager().activate(); + + 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/tags/travelsample-1.0/services/smsgateway-corba/src/main/java/scatours/smsgateway/SMSGatewayServant.java b/sca-java-1.x/tags/travelsample-1.0/services/smsgateway-corba/src/main/java/scatours/smsgateway/SMSGatewayServant.java new file mode 100644 index 0000000000..693a909dca --- /dev/null +++ b/sca-java-1.x/tags/travelsample-1.0/services/smsgateway-corba/src/main/java/scatours/smsgateway/SMSGatewayServant.java @@ -0,0 +1,30 @@ +/* + * 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.smsgateway; + +public class SMSGatewayServant extends SMSGatewayPOA { + + public boolean sendSMS(String fromNumber, String toNumber, String text) { + System.out.println("Sending SMS message"); + System.out.println("From: " + fromNumber); + System.out.println("To: " + toNumber); + System.out.println("Message: " + text); + return true; + } +} diff --git a/sca-java-1.x/tags/travelsample-1.0/services/smsgateway-corba/src/main/resources/sms-gateway.idl b/sca-java-1.x/tags/travelsample-1.0/services/smsgateway-corba/src/main/resources/sms-gateway.idl new file mode 100644 index 0000000000..30a87f5c7a --- /dev/null +++ b/sca-java-1.x/tags/travelsample-1.0/services/smsgateway-corba/src/main/resources/sms-gateway.idl @@ -0,0 +1,26 @@ +/* + * 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. + */ + + module scatours { + module smsgateway { + interface SMSGateway { + boolean sendSMS(in string fromNumber, in string toNumber, in string text); + }; + }; +}; -- cgit v1.2.3