From 8c049462ff6387d8c3f69f4e42a4c4b36e38a90c Mon Sep 17 00:00:00 2001 From: rfeng Date: Thu, 5 Nov 2009 21:14:49 +0000 Subject: Format the code git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@833174 13f79535-47bb-0310-9956-ffa450edef68 --- .../scatours/creditcard/CreditCardServiceImpl.java | 5 +- .../SMSGatewayCORBAServiceBootstrap.java | 20 ++-- .../scatours/smsgateway/SMSGatewayServant.java | 1 - .../smsgateway/SMSGatewayEJBServiceBootstrap.java | 22 ++--- .../main/java/scatours/smsgateway/SMSGateway.java | 1 - .../java/scatours/smsgateway/SMSGatewayImpl.java | 106 ++++++++++----------- .../smsgateway/SMSGatewayJMSServiceBootstrap.java | 15 ++- .../main/java/scatours/smsgateway/SMSGateway.java | 1 - .../smsgateway/SMSGatewayRMIServiceBootstrap.java | 20 ++-- 9 files changed, 93 insertions(+), 98 deletions(-) (limited to 'sandbox/travelsample/services') diff --git a/sandbox/travelsample/services/creditcard-payment-jaxws/src/main/java/scatours/creditcard/CreditCardServiceImpl.java b/sandbox/travelsample/services/creditcard-payment-jaxws/src/main/java/scatours/creditcard/CreditCardServiceImpl.java index aeb0632ed4..7118edbc1f 100644 --- a/sandbox/travelsample/services/creditcard-payment-jaxws/src/main/java/scatours/creditcard/CreditCardServiceImpl.java +++ b/sandbox/travelsample/services/creditcard-payment-jaxws/src/main/java/scatours/creditcard/CreditCardServiceImpl.java @@ -20,13 +20,12 @@ package scatours.creditcard; import javax.jws.WebService; -@WebService(endpointInterface - = "scatours.creditcard.CreditCardService") +@WebService(endpointInterface = "scatours.creditcard.CreditCardService") public class CreditCardServiceImpl implements CreditCardService { public String makePayment(String cardNumber, String name, double amount) { System.out.println("Payment request from " + name); - + if (cardNumber != null && cardNumber.startsWith("1")) { return "AUTH_ID:" + System.currentTimeMillis(); } diff --git a/sandbox/travelsample/services/smsgateway-corba/src/main/java/scatours/smsgateway/SMSGatewayCORBAServiceBootstrap.java b/sandbox/travelsample/services/smsgateway-corba/src/main/java/scatours/smsgateway/SMSGatewayCORBAServiceBootstrap.java index b21bff7a1b..3ea7f7de44 100644 --- a/sandbox/travelsample/services/smsgateway-corba/src/main/java/scatours/smsgateway/SMSGatewayCORBAServiceBootstrap.java +++ b/sandbox/travelsample/services/smsgateway-corba/src/main/java/scatours/smsgateway/SMSGatewayCORBAServiceBootstrap.java @@ -30,30 +30,30 @@ 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 ); + ORB orb = ORB.init(orbArgs, null); NamingContextExt namingCtx; try { - Object objRef = orb.resolve_initial_references("NameService"); - namingCtx = NamingContextExtHelper.narrow(objRef); + 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.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, "") }; + NameComponent[] name = {new NameComponent(corbaServerName, "")}; namingCtx.rebind(name, smsGatewayRef); System.out.println("CORBA server running - waiting for requests"); diff --git a/sandbox/travelsample/services/smsgateway-corba/src/main/java/scatours/smsgateway/SMSGatewayServant.java b/sandbox/travelsample/services/smsgateway-corba/src/main/java/scatours/smsgateway/SMSGatewayServant.java index 5e43b671a0..693a909dca 100644 --- a/sandbox/travelsample/services/smsgateway-corba/src/main/java/scatours/smsgateway/SMSGatewayServant.java +++ b/sandbox/travelsample/services/smsgateway-corba/src/main/java/scatours/smsgateway/SMSGatewayServant.java @@ -18,7 +18,6 @@ */ package scatours.smsgateway; - public class SMSGatewayServant extends SMSGatewayPOA { public boolean sendSMS(String fromNumber, String toNumber, String text) { diff --git a/sandbox/travelsample/services/smsgateway-ejb/src/main/java/scatours/smsgateway/SMSGatewayEJBServiceBootstrap.java b/sandbox/travelsample/services/smsgateway-ejb/src/main/java/scatours/smsgateway/SMSGatewayEJBServiceBootstrap.java index b807a53130..5c1a61f4dc 100644 --- a/sandbox/travelsample/services/smsgateway-ejb/src/main/java/scatours/smsgateway/SMSGatewayEJBServiceBootstrap.java +++ b/sandbox/travelsample/services/smsgateway-ejb/src/main/java/scatours/smsgateway/SMSGatewayEJBServiceBootstrap.java @@ -26,20 +26,20 @@ import javax.naming.InitialContext; public class SMSGatewayEJBServiceBootstrap { public static void main(String[] args) throws Exception { - System.out.println("Publishing SMS Gateway Service as an EJB service"); + System.out.println("Publishing SMS Gateway Service as an EJB service"); - Properties properties = new Properties(); - properties.setProperty(Context.INITIAL_CONTEXT_FACTORY, "org.apache.openejb.client.LocalInitialContextFactory"); - properties.setProperty("openejb.embedded.remotable", "true"); + Properties properties = new Properties(); + properties.setProperty(Context.INITIAL_CONTEXT_FACTORY, "org.apache.openejb.client.LocalInitialContextFactory"); + properties.setProperty("openejb.embedded.remotable", "true"); - InitialContext initialContext = new InitialContext(properties); + InitialContext initialContext = new InitialContext(properties); -// Object object = initialContext.lookup("SMSGatewayImplRemote"); -// SMSGateway smsGateway = (SMSGateway) object; -// smsGateway.sendSMS("From", "to", "Message"); + // Object object = initialContext.lookup("SMSGatewayImplRemote"); + // SMSGateway smsGateway = (SMSGateway) object; + // smsGateway.sendSMS("From", "to", "Message"); - System.out.println("EJB server running - waiting for requests"); - System.out.println("Press enter to shutdown."); - System.in.read(); + System.out.println("EJB server running - waiting for requests"); + System.out.println("Press enter to shutdown."); + System.in.read(); } } diff --git a/sandbox/travelsample/services/smsgateway-jms/src/main/java/scatours/smsgateway/SMSGateway.java b/sandbox/travelsample/services/smsgateway-jms/src/main/java/scatours/smsgateway/SMSGateway.java index a900dfecee..e6e866fa1d 100644 --- a/sandbox/travelsample/services/smsgateway-jms/src/main/java/scatours/smsgateway/SMSGateway.java +++ b/sandbox/travelsample/services/smsgateway-jms/src/main/java/scatours/smsgateway/SMSGateway.java @@ -22,7 +22,6 @@ package scatours.smsgateway; import java.rmi.Remote; import java.rmi.RemoteException; - /** * A gateway to send SMS messages. */ diff --git a/sandbox/travelsample/services/smsgateway-jms/src/main/java/scatours/smsgateway/SMSGatewayImpl.java b/sandbox/travelsample/services/smsgateway-jms/src/main/java/scatours/smsgateway/SMSGatewayImpl.java index adacac77f5..c35aa61513 100644 --- a/sandbox/travelsample/services/smsgateway-jms/src/main/java/scatours/smsgateway/SMSGatewayImpl.java +++ b/sandbox/travelsample/services/smsgateway-jms/src/main/java/scatours/smsgateway/SMSGatewayImpl.java @@ -44,83 +44,83 @@ public class SMSGatewayImpl implements SMSGateway { private final MessageProducer producer; public SMSGatewayImpl(Session session) throws JMSException { - this.session = session; - Destination requestDest = session.createQueue("SMSRequestQueue"); - consumer = session.createConsumer(requestDest); + this.session = session; + Destination requestDest = session.createQueue("SMSRequestQueue"); + consumer = session.createConsumer(requestDest); - Destination responseDest = session.createQueue("SMSResponseQueue"); - producer = session.createProducer(responseDest); + Destination responseDest = session.createQueue("SMSResponseQueue"); + producer = session.createProducer(responseDest); } public void start() throws JMSException, XMLStreamException { - while (true) { - Message message = consumer.receive(); - handleRequest(message); - } + while (true) { + Message message = consumer.receive(); + handleRequest(message); + } } private void handleRequest(Message inMessage) throws XMLStreamException, JMSException { - OMElement xml = parseXMLPayload(inMessage); + OMElement xml = parseXMLPayload(inMessage); - String fromNumber = getStringArg(xml, 0); - String toNumber = getStringArg(xml, 1); - String text = getStringArg(xml, 2); + String fromNumber = getStringArg(xml, 0); + String toNumber = getStringArg(xml, 1); + String text = getStringArg(xml, 2); - boolean result = sendSMS(fromNumber, toNumber, text); + boolean result = sendSMS(fromNumber, toNumber, text); - String responseXML = createXMLResponse(result); + String responseXML = createXMLResponse(result); - TextMessage outMessage = createResponseMessage(inMessage.getJMSMessageID(), responseXML); - producer.send(outMessage); + TextMessage outMessage = createResponseMessage(inMessage.getJMSMessageID(), responseXML); + producer.send(outMessage); } private OMElement parseXMLPayload(Message inMessage) throws JMSException, XMLStreamException { - final byte[] msgData; - if (inMessage instanceof TextMessage) { - msgData = ((TextMessage) inMessage).getText().getBytes(); - } else if (inMessage instanceof BytesMessage) { - BytesMessage bytesMessage = (BytesMessage) inMessage; - msgData = new byte[(int) bytesMessage.getBodyLength()]; - bytesMessage.readBytes(msgData); - } else { - throw new JMSException("Unsupported JMS message type of " + inMessage.getClass().getName()); - } - ByteArrayInputStream in = new ByteArrayInputStream(msgData); - StAXOMBuilder builder = new StAXOMBuilder(in); - OMElement doc = builder.getDocumentElement(); - return doc; + final byte[] msgData; + if (inMessage instanceof TextMessage) { + msgData = ((TextMessage)inMessage).getText().getBytes(); + } else if (inMessage instanceof BytesMessage) { + BytesMessage bytesMessage = (BytesMessage)inMessage; + msgData = new byte[(int)bytesMessage.getBodyLength()]; + bytesMessage.readBytes(msgData); + } else { + throw new JMSException("Unsupported JMS message type of " + inMessage.getClass().getName()); + } + ByteArrayInputStream in = new ByteArrayInputStream(msgData); + StAXOMBuilder builder = new StAXOMBuilder(in); + OMElement doc = builder.getDocumentElement(); + return doc; } private String getStringArg(OMElement doc, int i) { - QName argQName = new QName("arg" + i); - OMElement arg = doc.getFirstChildWithName(argQName); - if (arg == null) { - return null; - } - return arg.getText(); + QName argQName = new QName("arg" + i); + OMElement arg = doc.getFirstChildWithName(argQName); + if (arg == null) { + return null; + } + return arg.getText(); } public boolean sendSMS(String fromNumber, String toNumber, String text) { - System.out.println("From: " + fromNumber); - System.out.println("To: " + toNumber); - System.out.println(text); - return true; + System.out.println("From: " + fromNumber); + System.out.println("To: " + toNumber); + System.out.println(text); + return true; } private String createXMLResponse(boolean result) { - OMFactory omFactory = OMAbstractFactory.getOMFactory(); - OMElement response = omFactory.createOMElement("sendSMS", "http://smsgateway.scatours/", "ns2"); - OMElement returnValue = omFactory.createOMElement("return", null); - OMText returnV = omFactory.createOMText(Boolean.toString(result)); - returnValue.addChild(returnV); - response.addChild(returnValue); - return response.toString(); + OMFactory omFactory = OMAbstractFactory.getOMFactory(); + OMElement response = omFactory.createOMElement("sendSMS", "http://smsgateway.scatours/", "ns2"); + OMElement returnValue = omFactory.createOMElement("return", null); + OMText returnV = omFactory.createOMText(Boolean.toString(result)); + returnValue.addChild(returnV); + response.addChild(returnValue); + return response.toString(); } private TextMessage createResponseMessage(String correlationID, String responseXML) throws JMSException { - TextMessage outMessage = session.createTextMessage("sendSMS"); - outMessage.setText(responseXML); - outMessage.setJMSCorrelationID(correlationID); - return outMessage; + TextMessage outMessage = session.createTextMessage("sendSMS"); + outMessage.setText(responseXML); + outMessage.setJMSCorrelationID(correlationID); + return outMessage; } - } +} diff --git a/sandbox/travelsample/services/smsgateway-jms/src/main/java/scatours/smsgateway/SMSGatewayJMSServiceBootstrap.java b/sandbox/travelsample/services/smsgateway-jms/src/main/java/scatours/smsgateway/SMSGatewayJMSServiceBootstrap.java index 3e5668ed23..d27635f0c3 100644 --- a/sandbox/travelsample/services/smsgateway-jms/src/main/java/scatours/smsgateway/SMSGatewayJMSServiceBootstrap.java +++ b/sandbox/travelsample/services/smsgateway-jms/src/main/java/scatours/smsgateway/SMSGatewayJMSServiceBootstrap.java @@ -26,15 +26,14 @@ import org.apache.activemq.ActiveMQConnectionFactory; public class SMSGatewayJMSServiceBootstrap { public static void main(String[] args) throws Exception { - System.out.println("Publishing SMS Gateway Service as a JMS service: tcp://localhost:61619"); + System.out.println("Publishing SMS Gateway Service as a JMS service: tcp://localhost:61619"); - ActiveMQConnectionFactory connectionFactory - = new ActiveMQConnectionFactory("tcp://localhost:61619"); - Connection connection = connectionFactory.createConnection(); - connection.start(); - Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61619"); + Connection connection = connectionFactory.createConnection(); + connection.start(); + Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); - SMSGatewayImpl impl = new SMSGatewayImpl(session); - impl.start(); + SMSGatewayImpl impl = new SMSGatewayImpl(session); + impl.start(); } } diff --git a/sandbox/travelsample/services/smsgateway-rmi/src/main/java/scatours/smsgateway/SMSGateway.java b/sandbox/travelsample/services/smsgateway-rmi/src/main/java/scatours/smsgateway/SMSGateway.java index a900dfecee..e6e866fa1d 100644 --- a/sandbox/travelsample/services/smsgateway-rmi/src/main/java/scatours/smsgateway/SMSGateway.java +++ b/sandbox/travelsample/services/smsgateway-rmi/src/main/java/scatours/smsgateway/SMSGateway.java @@ -22,7 +22,6 @@ package scatours.smsgateway; import java.rmi.Remote; import java.rmi.RemoteException; - /** * A gateway to send SMS messages. */ diff --git a/sandbox/travelsample/services/smsgateway-rmi/src/main/java/scatours/smsgateway/SMSGatewayRMIServiceBootstrap.java b/sandbox/travelsample/services/smsgateway-rmi/src/main/java/scatours/smsgateway/SMSGatewayRMIServiceBootstrap.java index 2c4c96299e..b13f3d2aee 100644 --- a/sandbox/travelsample/services/smsgateway-rmi/src/main/java/scatours/smsgateway/SMSGatewayRMIServiceBootstrap.java +++ b/sandbox/travelsample/services/smsgateway-rmi/src/main/java/scatours/smsgateway/SMSGatewayRMIServiceBootstrap.java @@ -24,17 +24,17 @@ import java.rmi.registry.Registry; public class SMSGatewayRMIServiceBootstrap { public static void main(String[] args) throws Exception { - System.out.println("Publishing SMS Gateway Service as a RMI service"); + System.out.println("Publishing SMS Gateway Service as a RMI service"); - String serviceName = "SMSGatewayRMI"; - SMSGatewayImpl smsGatewayImpl = new SMSGatewayImpl(); - Registry rmiRegistry = LocateRegistry.createRegistry(8099); - rmiRegistry.bind(serviceName, smsGatewayImpl); + String serviceName = "SMSGatewayRMI"; + SMSGatewayImpl smsGatewayImpl = new SMSGatewayImpl(); + Registry rmiRegistry = LocateRegistry.createRegistry(8099); + rmiRegistry.bind(serviceName, smsGatewayImpl); - System.out.println("RMI server running - waiting for requests"); - System.out.println("Press enter to shutdown."); - System.in.read(); - rmiRegistry.unbind(serviceName); - System.exit(-1); + System.out.println("RMI server running - waiting for requests"); + System.out.println("Press enter to shutdown."); + System.in.read(); + rmiRegistry.unbind(serviceName); + System.exit(-1); } } -- cgit v1.2.3