diff options
Diffstat (limited to '')
9 files changed, 93 insertions, 98 deletions
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);
}
}
|