diff options
Diffstat (limited to '')
35 files changed, 223 insertions, 248 deletions
diff --git a/sandbox/travelsample/launchers/blog-feed/src/main/java/scatours/BlogFeedLauncher.java b/sandbox/travelsample/launchers/blog-feed/src/main/java/scatours/BlogFeedLauncher.java index 54d94ec046..8dc6956986 100644 --- a/sandbox/travelsample/launchers/blog-feed/src/main/java/scatours/BlogFeedLauncher.java +++ b/sandbox/travelsample/launchers/blog-feed/src/main/java/scatours/BlogFeedLauncher.java @@ -28,11 +28,9 @@ import org.apache.tuscany.sca.node.SCANodeFactory; public class BlogFeedLauncher {
public static void main(String[] args) throws Exception {
- SCAContribution feedContribution =
- locate("blog-feed");
+ SCAContribution feedContribution = locate("blog-feed");
- SCANode node = SCANodeFactory.newInstance().createSCANode(
- "blog-feed.composite", feedContribution);
+ SCANode node = SCANodeFactory.newInstance().createSCANode("blog-feed.composite", feedContribution);
node.start();
System.out.println("Node started - Press enter to shutdown.");
diff --git a/sandbox/travelsample/launchers/currency-converter-corba/src/main/java/scatours/CurrencyConverterCORBALauncher.java b/sandbox/travelsample/launchers/currency-converter-corba/src/main/java/scatours/CurrencyConverterCORBALauncher.java index d18acc6df1..0f9d0eca80 100644 --- a/sandbox/travelsample/launchers/currency-converter-corba/src/main/java/scatours/CurrencyConverterCORBALauncher.java +++ b/sandbox/travelsample/launchers/currency-converter-corba/src/main/java/scatours/CurrencyConverterCORBALauncher.java @@ -31,22 +31,19 @@ import scatours.currencyconverter.CurrencyConverter; public class CurrencyConverterCORBALauncher {
public static void main(String[] args) throws Exception {
- SCAContribution currencyCORBAContribution =
- locate("currency-corba");
- SCAContribution currencyContribution =
- locate("currency");
-
- SCANode node = SCANodeFactory.newInstance().createSCANode(
- "currency-converter-corba.composite", currencyContribution, currencyCORBAContribution);
+ SCAContribution currencyCORBAContribution = locate("currency-corba");
+ SCAContribution currencyContribution = locate("currency");
+
+ SCANode node =
+ SCANodeFactory.newInstance().createSCANode("currency-converter-corba.composite",
+ currencyContribution,
+ currencyCORBAContribution);
node.start();
System.out.println("Quick currency converter test");
- CurrencyConverter converter = ((SCAClient)node).getService(
- CurrencyConverter.class, "CurrencyConverter");
- System.out.println("USD -> GBP = "
- + converter.getExchangeRate("USD", "GBP"));
- System.out.println("100 USD = "
- + converter.convert("USD", "GBP", 100) + "GBP");
+ CurrencyConverter converter = ((SCAClient)node).getService(CurrencyConverter.class, "CurrencyConverter");
+ System.out.println("USD -> GBP = " + converter.getExchangeRate("USD", "GBP"));
+ System.out.println("100 USD = " + converter.convert("USD", "GBP", 100) + "GBP");
System.out.println("Node started - Press enter to shutdown.");
System.in.read();
diff --git a/sandbox/travelsample/launchers/currency-converter-corba/src/main/java/scatours/currencyconverter/CurrencyConverter.java b/sandbox/travelsample/launchers/currency-converter-corba/src/main/java/scatours/currencyconverter/CurrencyConverter.java index 6d0efc8c66..fe5c98bf02 100644 --- a/sandbox/travelsample/launchers/currency-converter-corba/src/main/java/scatours/currencyconverter/CurrencyConverter.java +++ b/sandbox/travelsample/launchers/currency-converter-corba/src/main/java/scatours/currencyconverter/CurrencyConverter.java @@ -26,11 +26,8 @@ import org.osoa.sca.annotations.Remotable; @Remotable
public interface CurrencyConverter {
- double getExchangeRate(String fromCurrencyCode,
- String toCurrencyCode);
-
- double convert(String fromCurrencyCode,
- String toCurrencyCode,
- double amount);
+ double getExchangeRate(String fromCurrencyCode, String toCurrencyCode);
+
+ double convert(String fromCurrencyCode, String toCurrencyCode, double amount);
}
diff --git a/sandbox/travelsample/launchers/currency-converter-jms/src/main/java/scatours/CurrencyConverterJMSLauncher.java b/sandbox/travelsample/launchers/currency-converter-jms/src/main/java/scatours/CurrencyConverterJMSLauncher.java index 08a0d8430a..9de41eb478 100644 --- a/sandbox/travelsample/launchers/currency-converter-jms/src/main/java/scatours/CurrencyConverterJMSLauncher.java +++ b/sandbox/travelsample/launchers/currency-converter-jms/src/main/java/scatours/CurrencyConverterJMSLauncher.java @@ -31,8 +31,10 @@ public class CurrencyConverterJMSLauncher { SCAContribution currencyJMSContribution = locate("currency-jms");
SCAContribution currencyContribution = locate("currency");
- SCANode node = SCANodeFactory.newInstance().createSCANode(
- "currency-converter-jms.composite", currencyContribution, currencyJMSContribution);
+ SCANode node =
+ SCANodeFactory.newInstance().createSCANode("currency-converter-jms.composite",
+ currencyContribution,
+ currencyJMSContribution);
node.start();
System.out.println("Node started - Press enter to shutdown.");
diff --git a/sandbox/travelsample/launchers/currency-converter-jms/src/main/java/scatours/JMSBrokerLauncher.java b/sandbox/travelsample/launchers/currency-converter-jms/src/main/java/scatours/JMSBrokerLauncher.java index 7d063ca865..929eb78431 100644 --- a/sandbox/travelsample/launchers/currency-converter-jms/src/main/java/scatours/JMSBrokerLauncher.java +++ b/sandbox/travelsample/launchers/currency-converter-jms/src/main/java/scatours/JMSBrokerLauncher.java @@ -23,16 +23,16 @@ 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(); + 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(); + System.out.println("JMS Message Broker started"); + System.out.println("Press enter to shutdown."); + System.in.read(); - jmsBroker.stop(); + jmsBroker.stop(); } - } +} diff --git a/sandbox/travelsample/launchers/currency-converter-rmi/src/main/java/com/tuscanyscatours/currencyconverter/CurrencyConverter.java b/sandbox/travelsample/launchers/currency-converter-rmi/src/main/java/com/tuscanyscatours/currencyconverter/CurrencyConverter.java index 24d945b2f4..b1f783bfba 100644 --- a/sandbox/travelsample/launchers/currency-converter-rmi/src/main/java/com/tuscanyscatours/currencyconverter/CurrencyConverter.java +++ b/sandbox/travelsample/launchers/currency-converter-rmi/src/main/java/com/tuscanyscatours/currencyconverter/CurrencyConverter.java @@ -26,11 +26,8 @@ import org.osoa.sca.annotations.Remotable; @Remotable
public interface CurrencyConverter {
- double getExchangeRate(String fromCurrencyCode,
- String toCurrencyCode);
-
- double convert(String fromCurrencyCode,
- String toCurrencyCode,
- double amount);
+ double getExchangeRate(String fromCurrencyCode, String toCurrencyCode);
+
+ double convert(String fromCurrencyCode, String toCurrencyCode, double amount);
}
diff --git a/sandbox/travelsample/launchers/currency-converter-rmi/src/main/java/scatours/CurrencyConverterRMILauncher.java b/sandbox/travelsample/launchers/currency-converter-rmi/src/main/java/scatours/CurrencyConverterRMILauncher.java index 87660bdfb6..b509cfef5c 100644 --- a/sandbox/travelsample/launchers/currency-converter-rmi/src/main/java/scatours/CurrencyConverterRMILauncher.java +++ b/sandbox/travelsample/launchers/currency-converter-rmi/src/main/java/scatours/CurrencyConverterRMILauncher.java @@ -31,22 +31,19 @@ import com.tuscanyscatours.currencyconverter.CurrencyConverter; public class CurrencyConverterRMILauncher {
public static void main(String[] args) throws Exception {
- SCAContribution currencyRMIContribution =
- locate("currency-rmi");
- SCAContribution currencyContribution =
- locate("currency");
-
- SCANode node = SCANodeFactory.newInstance().createSCANode(
- "currency-converter-rmi.composite", currencyContribution, currencyRMIContribution);
+ SCAContribution currencyRMIContribution = locate("currency-rmi");
+ SCAContribution currencyContribution = locate("currency");
+
+ SCANode node =
+ SCANodeFactory.newInstance().createSCANode("currency-converter-rmi.composite",
+ currencyContribution,
+ currencyRMIContribution);
node.start();
System.out.println("Quick currency converter test");
- CurrencyConverter converter = ((SCAClient)node).getService(
- CurrencyConverter.class, "CurrencyConverter");
- System.out.println("USD -> GBP = "
- + converter.getExchangeRate("USD", "GBP"));
- System.out.println("100 USD = "
- + converter.convert("USD", "GBP", 100) + "GBP");
+ CurrencyConverter converter = ((SCAClient)node).getService(CurrencyConverter.class, "CurrencyConverter");
+ System.out.println("USD -> GBP = " + converter.getExchangeRate("USD", "GBP"));
+ System.out.println("100 USD = " + converter.convert("USD", "GBP", 100) + "GBP");
System.out.println("Node started - Press enter to shutdown.");
System.in.read();
diff --git a/sandbox/travelsample/launchers/currency-converter-ws/src/main/java/scatours/CurrencyConverterWSLauncher.java b/sandbox/travelsample/launchers/currency-converter-ws/src/main/java/scatours/CurrencyConverterWSLauncher.java index 36b907d454..2425d3f483 100644 --- a/sandbox/travelsample/launchers/currency-converter-ws/src/main/java/scatours/CurrencyConverterWSLauncher.java +++ b/sandbox/travelsample/launchers/currency-converter-ws/src/main/java/scatours/CurrencyConverterWSLauncher.java @@ -31,22 +31,19 @@ import scatours.currencyconverter.CurrencyConverter; public class CurrencyConverterWSLauncher {
public static void main(String[] args) throws Exception {
- SCAContribution currencyWSContribution =
- locate("currency-ws");
- SCAContribution currencyContribution =
- locate("currency");
-
- SCANode node = SCANodeFactory.newInstance().createSCANode(
- "currency-converter-ws.composite", currencyContribution, currencyWSContribution);
+ SCAContribution currencyWSContribution = locate("currency-ws");
+ SCAContribution currencyContribution = locate("currency");
+
+ SCANode node =
+ SCANodeFactory.newInstance().createSCANode("currency-converter-ws.composite",
+ currencyContribution,
+ currencyWSContribution);
node.start();
System.out.println("Quick currency converter test");
- CurrencyConverter converter = ((SCAClient)node).getService(
- CurrencyConverter.class, "CurrencyConverter");
- System.out.println("USD -> GBP = "
- + converter.getExchangeRate("USD", "GBP"));
- System.out.println("100 USD = "
- + converter.convert("USD", "GBP", 100) + "GBP");
+ CurrencyConverter converter = ((SCAClient)node).getService(CurrencyConverter.class, "CurrencyConverter");
+ System.out.println("USD -> GBP = " + converter.getExchangeRate("USD", "GBP"));
+ System.out.println("100 USD = " + converter.convert("USD", "GBP", 100) + "GBP");
System.out.println("Node started - Press enter to shutdown.");
System.in.read();
diff --git a/sandbox/travelsample/launchers/currency-converter-ws/src/main/java/scatours/currencyconverter/CurrencyConverter.java b/sandbox/travelsample/launchers/currency-converter-ws/src/main/java/scatours/currencyconverter/CurrencyConverter.java index 6d0efc8c66..fe5c98bf02 100644 --- a/sandbox/travelsample/launchers/currency-converter-ws/src/main/java/scatours/currencyconverter/CurrencyConverter.java +++ b/sandbox/travelsample/launchers/currency-converter-ws/src/main/java/scatours/currencyconverter/CurrencyConverter.java @@ -26,11 +26,8 @@ import org.osoa.sca.annotations.Remotable; @Remotable
public interface CurrencyConverter {
- double getExchangeRate(String fromCurrencyCode,
- String toCurrencyCode);
-
- double convert(String fromCurrencyCode,
- String toCurrencyCode,
- double amount);
+ double getExchangeRate(String fromCurrencyCode, String toCurrencyCode);
+
+ double convert(String fromCurrencyCode, String toCurrencyCode, double amount);
}
diff --git a/sandbox/travelsample/launchers/currency-converter/src/main/java/scatours/CurrencyConverterLauncher.java b/sandbox/travelsample/launchers/currency-converter/src/main/java/scatours/CurrencyConverterLauncher.java index 9e8385e9af..cacd579b3b 100644 --- a/sandbox/travelsample/launchers/currency-converter/src/main/java/scatours/CurrencyConverterLauncher.java +++ b/sandbox/travelsample/launchers/currency-converter/src/main/java/scatours/CurrencyConverterLauncher.java @@ -31,20 +31,15 @@ import scatours.currencyconverter.CurrencyConverter; public class CurrencyConverterLauncher {
public static void main(String[] args) throws Exception {
- SCAContribution currencyContribution =
- locate("currency");
-
- SCANode node = SCANodeFactory.newInstance().createSCANode(
- "currency-converter.composite", currencyContribution);
+ SCAContribution currencyContribution = locate("currency");
+
+ SCANode node = SCANodeFactory.newInstance().createSCANode("currency-converter.composite", currencyContribution);
node.start();
System.out.println("Quick currency converter test");
- CurrencyConverter converter = ((SCAClient)node).getService(
- CurrencyConverter.class, "CurrencyConverter");
- System.out.println("USD -> GBP = "
- + converter.getExchangeRate("USD", "GBP"));
- System.out.println("100 USD = "
- + converter.convert("USD", "GBP", 100) + "GBP");
+ CurrencyConverter converter = ((SCAClient)node).getService(CurrencyConverter.class, "CurrencyConverter");
+ System.out.println("USD -> GBP = " + converter.getExchangeRate("USD", "GBP"));
+ System.out.println("100 USD = " + converter.convert("USD", "GBP", 100) + "GBP");
System.out.println("Node started - Press enter to shutdown.");
System.in.read();
diff --git a/sandbox/travelsample/launchers/currency-converter/src/main/java/scatours/currencyconverter/CurrencyConverter.java b/sandbox/travelsample/launchers/currency-converter/src/main/java/scatours/currencyconverter/CurrencyConverter.java index 6d0efc8c66..fe5c98bf02 100644 --- a/sandbox/travelsample/launchers/currency-converter/src/main/java/scatours/currencyconverter/CurrencyConverter.java +++ b/sandbox/travelsample/launchers/currency-converter/src/main/java/scatours/currencyconverter/CurrencyConverter.java @@ -26,11 +26,8 @@ import org.osoa.sca.annotations.Remotable; @Remotable
public interface CurrencyConverter {
- double getExchangeRate(String fromCurrencyCode,
- String toCurrencyCode);
-
- double convert(String fromCurrencyCode,
- String toCurrencyCode,
- double amount);
+ double getExchangeRate(String fromCurrencyCode, String toCurrencyCode);
+
+ double convert(String fromCurrencyCode, String toCurrencyCode, double amount);
}
diff --git a/sandbox/travelsample/launchers/databinding/src/main/java/scatours/DatabindingLauncher.java b/sandbox/travelsample/launchers/databinding/src/main/java/scatours/DatabindingLauncher.java index 1ae22baca6..61f6b74582 100644 --- a/sandbox/travelsample/launchers/databinding/src/main/java/scatours/DatabindingLauncher.java +++ b/sandbox/travelsample/launchers/databinding/src/main/java/scatours/DatabindingLauncher.java @@ -27,19 +27,16 @@ import org.apache.tuscany.sca.node.SCANodeFactory; public class DatabindingLauncher { public static void main(String[] args) throws Exception { - SCANode node1 = SCANodeFactory.newInstance().createSCANode(null, - locate("paymentjava"), - locate("client")); - - SCANode node2 = SCANodeFactory.newInstance().createSCANode(null, - locate("creditcardpaymentsdo")); - + SCANode node1 = SCANodeFactory.newInstance().createSCANode(null, locate("paymentjava"), locate("client")); + + SCANode node2 = SCANodeFactory.newInstance().createSCANode(null, locate("creditcardpaymentsdo")); + node1.start(); node2.start(); Runnable runner = ((SCAClient)node1).getService(Runnable.class, "TestClient/Runnable"); runner.run(); - + node1.stop(); node2.stop(); } diff --git a/sandbox/travelsample/launchers/feed-logger/src/main/java/scatours/FeedLoggerLauncher.java b/sandbox/travelsample/launchers/feed-logger/src/main/java/scatours/FeedLoggerLauncher.java index 73970b12ca..4aea24dbfe 100644 --- a/sandbox/travelsample/launchers/feed-logger/src/main/java/scatours/FeedLoggerLauncher.java +++ b/sandbox/travelsample/launchers/feed-logger/src/main/java/scatours/FeedLoggerLauncher.java @@ -31,15 +31,12 @@ import scatours.feedlogger.FeedLogger; public class FeedLoggerLauncher {
public static void main(String[] args) throws Exception {
- SCAContribution feedContribution =
- locate("feed-logger");
+ SCAContribution feedContribution = locate("feed-logger");
- SCANode node = SCANodeFactory.newInstance().createSCANode(
- "feed-logger.composite", feedContribution);
+ SCANode node = SCANodeFactory.newInstance().createSCANode("feed-logger.composite", feedContribution);
node.start();
-
- FeedLogger logger = ((SCAClient)node).getService(
- FeedLogger.class, "FeedLogger");
+
+ FeedLogger logger = ((SCAClient)node).getService(FeedLogger.class, "FeedLogger");
logger.logFeeds(5);
node.stop();
diff --git a/sandbox/travelsample/launchers/fullapp-nodes/src/main/java/scatours/FullAppNodesLauncher.java b/sandbox/travelsample/launchers/fullapp-nodes/src/main/java/scatours/FullAppNodesLauncher.java index 6367bb60f3..3b9a2b5f90 100644 --- a/sandbox/travelsample/launchers/fullapp-nodes/src/main/java/scatours/FullAppNodesLauncher.java +++ b/sandbox/travelsample/launchers/fullapp-nodes/src/main/java/scatours/FullAppNodesLauncher.java @@ -25,27 +25,34 @@ import org.apache.tuscany.sca.node.SCANode; import org.apache.tuscany.sca.node.SCANodeFactory; public class FullAppNodesLauncher { - + public static void main(String[] args) throws Exception { - SCANode nodeCreditcard = SCANodeFactory.newInstance().createSCANodeFromURL("http://localhost:9990/node-config/creditcard"); + SCANode nodeCreditcard = + SCANodeFactory.newInstance().createSCANodeFromURL("http://localhost:9990/node-config/creditcard"); nodeCreditcard.start(); - SCANode nodePayment = SCANodeFactory.newInstance().createSCANodeFromURL("http://localhost:9990/node-config/payment"); - nodePayment.start(); + SCANode nodePayment = + SCANodeFactory.newInstance().createSCANodeFromURL("http://localhost:9990/node-config/payment"); + nodePayment.start(); - SCANode nodeShoppingcart = SCANodeFactory.newInstance().createSCANodeFromURL("http://localhost:9990/node-config/shoppingcart"); - nodeShoppingcart.start(); + SCANode nodeShoppingcart = + SCANodeFactory.newInstance().createSCANodeFromURL("http://localhost:9990/node-config/shoppingcart"); + nodeShoppingcart.start(); - SCANode nodeCurrency = SCANodeFactory.newInstance().createSCANodeFromURL("http://localhost:9990/node-config/currency"); + SCANode nodeCurrency = + SCANodeFactory.newInstance().createSCANodeFromURL("http://localhost:9990/node-config/currency"); nodeCurrency.start(); - SCANode nodePackagedtrip = SCANodeFactory.newInstance().createSCANodeFromURL("http://localhost:9990/node-config/packagedtrip"); - nodePackagedtrip.start(); + SCANode nodePackagedtrip = + SCANodeFactory.newInstance().createSCANodeFromURL("http://localhost:9990/node-config/packagedtrip"); + nodePackagedtrip.start(); - SCANode nodeBespoketrip = SCANodeFactory.newInstance().createSCANodeFromURL("http://localhost:9990/node-config/bespoketrip"); + SCANode nodeBespoketrip = + SCANodeFactory.newInstance().createSCANodeFromURL("http://localhost:9990/node-config/bespoketrip"); nodeBespoketrip.start(); - SCANode nodeFrontend = SCANodeFactory.newInstance().createSCANodeFromURL("http://localhost:9990/node-config/frontend"); + SCANode nodeFrontend = + SCANodeFactory.newInstance().createSCANodeFromURL("http://localhost:9990/node-config/frontend"); nodeFrontend.start(); SCANode nodeUI = SCANodeFactory.newInstance().createSCANodeFromURL("http://localhost:9990/node-config/ui"); @@ -55,14 +62,15 @@ public class FullAppNodesLauncher { try { System.in.read(); - } catch (IOException e) {} + } catch (IOException e) { + } nodeCreditcard.stop(); nodePayment.stop(); nodeShoppingcart.stop(); nodeCurrency.stop(); nodePackagedtrip.stop(); - nodeBespoketrip.stop(); + nodeBespoketrip.stop(); nodeFrontend.stop(); nodeUI.stop(); } diff --git a/sandbox/travelsample/launchers/fullapp/src/main/java/scatours/FullAppLauncher.java b/sandbox/travelsample/launchers/fullapp/src/main/java/scatours/FullAppLauncher.java index e9496eef8e..5e533c77c6 100644 --- a/sandbox/travelsample/launchers/fullapp/src/main/java/scatours/FullAppLauncher.java +++ b/sandbox/travelsample/launchers/fullapp/src/main/java/scatours/FullAppLauncher.java @@ -28,7 +28,6 @@ import org.apache.tuscany.sca.node.SCANodeFactory; public class FullAppLauncher { - public static void main(String[] args) throws Exception { SCANode node = SCANodeFactory.newInstance().createSCANode(null, diff --git a/sandbox/travelsample/launchers/help-pages/src/main/java/scatours/HelpPagesLauncher.java b/sandbox/travelsample/launchers/help-pages/src/main/java/scatours/HelpPagesLauncher.java index 097e05e7e5..a72f5c4c54 100644 --- a/sandbox/travelsample/launchers/help-pages/src/main/java/scatours/HelpPagesLauncher.java +++ b/sandbox/travelsample/launchers/help-pages/src/main/java/scatours/HelpPagesLauncher.java @@ -28,11 +28,9 @@ import org.apache.tuscany.sca.node.SCANodeFactory; public class HelpPagesLauncher {
public static void main(String[] args) throws Exception {
- SCAContribution helpContribution =
- locate("help-pages");
+ SCAContribution helpContribution = locate("help-pages");
- SCANode node = SCANodeFactory.newInstance().createSCANode(
- "help-pages.composite", helpContribution);
+ SCANode node = SCANodeFactory.newInstance().createSCANode("help-pages.composite", helpContribution);
node.start();
System.out.println("Node started - Press enter to shutdown.");
diff --git a/sandbox/travelsample/launchers/interaction/src/main/java/scatours/InteractionLauncher.java b/sandbox/travelsample/launchers/interaction/src/main/java/scatours/InteractionLauncher.java index 93f6f435ee..292b10aaf0 100644 --- a/sandbox/travelsample/launchers/interaction/src/main/java/scatours/InteractionLauncher.java +++ b/sandbox/travelsample/launchers/interaction/src/main/java/scatours/InteractionLauncher.java @@ -28,41 +28,47 @@ import org.apache.tuscany.sca.node.SCANodeFactory; public class InteractionLauncher {
public static void main(String[] args) throws Exception {
- SCANode node1 = SCANodeFactory.newInstance().createSCANode("client.composite",
- locate("common"),
- locate("currency"),
- locate("calendar"),
- locate("shoppingcart"),
- locate("interaction-client"));
-
- SCANode node2 = SCANodeFactory.newInstance().createSCANode("service.composite",
- locate("common"),
- locate("hotel"),
- locate("flight"),
- locate("interaction-service-remote"));
+ SCANode node1 =
+ SCANodeFactory.newInstance().createSCANode("client.composite",
+ locate("common"),
+ locate("currency"),
+ locate("calendar"),
+ locate("shoppingcart"),
+ locate("interaction-client"));
- node2.start();
+ SCANode node2 =
+ SCANodeFactory.newInstance().createSCANode("service.composite",
+ locate("common"),
+ locate("hotel"),
+ locate("flight"),
+ locate("interaction-service-remote"));
+
+ node2.start();
node1.start();
-
+
Runnable localInteraction = ((SCAClient)node1).getService(Runnable.class, "InteractionLocalClient/Runnable");
localInteraction.run();
-
+
Runnable remoteInteraction = ((SCAClient)node1).getService(Runnable.class, "InteractionRemoteClient/Runnable");
- remoteInteraction.run();
-
- Runnable requestResponseInteraction = ((SCAClient)node1).getService(Runnable.class, "InteractionRequestResponseClient/Runnable");
+ remoteInteraction.run();
+
+ Runnable requestResponseInteraction =
+ ((SCAClient)node1).getService(Runnable.class, "InteractionRequestResponseClient/Runnable");
requestResponseInteraction.run();
-
- Runnable onewayCallbackInteraction = ((SCAClient)node1).getService(Runnable.class, "InteractionOneWayCallbackClient/Runnable");
+
+ Runnable onewayCallbackInteraction =
+ ((SCAClient)node1).getService(Runnable.class, "InteractionOneWayCallbackClient/Runnable");
onewayCallbackInteraction.run();
-
- Runnable conversationalInteraction = ((SCAClient)node1).getService(Runnable.class, "InteractionConversationClient/Runnable");
+
+ Runnable conversationalInteraction =
+ ((SCAClient)node1).getService(Runnable.class, "InteractionConversationClient/Runnable");
conversationalInteraction.run();
-
- Runnable statefulCallbackInteraction = ((SCAClient)node1).getService(Runnable.class, "InteractionStatefulCallbackClient/Runnable");
- statefulCallbackInteraction.run();
-
+
+ Runnable statefulCallbackInteraction =
+ ((SCAClient)node1).getService(Runnable.class, "InteractionStatefulCallbackClient/Runnable");
+ statefulCallbackInteraction.run();
+
node1.stop();
node2.stop();
- }
+ }
}
diff --git a/sandbox/travelsample/launchers/interaction/src/test/java/scatours/InteractionTestCase.java b/sandbox/travelsample/launchers/interaction/src/test/java/scatours/InteractionTestCase.java index c674cdcd75..c64e5d1e5b 100644 --- a/sandbox/travelsample/launchers/interaction/src/test/java/scatours/InteractionTestCase.java +++ b/sandbox/travelsample/launchers/interaction/src/test/java/scatours/InteractionTestCase.java @@ -35,7 +35,7 @@ public class InteractionTestCase { public void testLauncher() throws Exception {
InteractionLauncher.main(null);
}
-
+
@After
public void stopServer() throws Exception {
}
diff --git a/sandbox/travelsample/launchers/introducing-client/src/main/java/scatours/IntroducingClientLauncher.java b/sandbox/travelsample/launchers/introducing-client/src/main/java/scatours/IntroducingClientLauncher.java index b45a14cd9c..f261ef6e27 100644 --- a/sandbox/travelsample/launchers/introducing-client/src/main/java/scatours/IntroducingClientLauncher.java +++ b/sandbox/travelsample/launchers/introducing-client/src/main/java/scatours/IntroducingClientLauncher.java @@ -26,12 +26,13 @@ import org.apache.tuscany.sca.node.SCANodeFactory; public class IntroducingClientLauncher {
public static void main(String[] args) throws Exception {
- SCANode node = SCANodeFactory.newInstance().createSCANodeFromURL("http://localhost:9990/node-config/ClientNode");
+ SCANode node =
+ SCANodeFactory.newInstance().createSCANodeFromURL("http://localhost:9990/node-config/ClientNode");
node.start();
Runnable client = ((SCAClient)node).getService(Runnable.class, "TestClient/Runnable");
client.run();
-
+
node.stop();
}
}
diff --git a/sandbox/travelsample/launchers/introducing/src/main/java/scatours/IntroducingLauncher.java b/sandbox/travelsample/launchers/introducing/src/main/java/scatours/IntroducingLauncher.java index bef43d9c7a..4ad19762d9 100644 --- a/sandbox/travelsample/launchers/introducing/src/main/java/scatours/IntroducingLauncher.java +++ b/sandbox/travelsample/launchers/introducing/src/main/java/scatours/IntroducingLauncher.java @@ -28,16 +28,17 @@ import org.apache.tuscany.sca.node.SCANodeFactory; public class IntroducingLauncher { public static void main(String[] args) throws Exception { - SCANode node = SCANodeFactory.newInstance().createSCANode(null, - locate("introducing-tours"), - locate("introducing-trips"), - locate("introducing-client")); + SCANode node = + SCANodeFactory.newInstance().createSCANode(null, + locate("introducing-tours"), + locate("introducing-trips"), + locate("introducing-client")); node.start(); Runnable proxy = ((SCAClient)node).getService(Runnable.class, "TestClient/Runnable"); proxy.run(); - + node.stop(); } } diff --git a/sandbox/travelsample/launchers/introducing/src/test/java/scatours/IntroducingTestCase.java b/sandbox/travelsample/launchers/introducing/src/test/java/scatours/IntroducingTestCase.java index e31e8e70ab..573d2e76bd 100644 --- a/sandbox/travelsample/launchers/introducing/src/test/java/scatours/IntroducingTestCase.java +++ b/sandbox/travelsample/launchers/introducing/src/test/java/scatours/IntroducingTestCase.java @@ -37,10 +37,15 @@ public class IntroducingTestCase { @Before
public void startServer() throws Exception {
- node = SCANodeFactory.newInstance().createSCANode(null,
- new SCAContribution("introducing-tours", "../../contributions/introducing-tours/target/classes"),
- new SCAContribution("introducing-trips", "../../contributions/introducing-trips/target/classes"),
- new SCAContribution("introducing-client", "../../contributions/introducing-client/target/classes"));
+ node =
+ SCANodeFactory.newInstance()
+ .createSCANode(null,
+ new SCAContribution("introducing-tours",
+ "../../contributions/introducing-tours/target/classes"),
+ new SCAContribution("introducing-trips",
+ "../../contributions/introducing-trips/target/classes"),
+ new SCAContribution("introducing-client",
+ "../../contributions/introducing-client/target/classes"));
node.start();
}
diff --git a/sandbox/travelsample/launchers/jumpstart/src/main/java/scatours/JumpstartLauncher.java b/sandbox/travelsample/launchers/jumpstart/src/main/java/scatours/JumpstartLauncher.java index 8c6f19f1db..544043884b 100644 --- a/sandbox/travelsample/launchers/jumpstart/src/main/java/scatours/JumpstartLauncher.java +++ b/sandbox/travelsample/launchers/jumpstart/src/main/java/scatours/JumpstartLauncher.java @@ -29,20 +29,15 @@ import org.apache.tuscany.sca.node.SCANodeFactory; public class JumpstartLauncher {
public static void main(String[] args) throws Exception {
- SCAContribution gvtContribution =
- locate("introducing-trips");
-
- SCANode node = SCANodeFactory.newInstance().
- createSCANode("trips.composite",
- gvtContribution);
-
+ SCAContribution gvtContribution = locate("introducing-trips");
+
+ SCANode node = SCANodeFactory.newInstance().createSCANode("trips.composite", gvtContribution);
+
node.start();
- Trips tripProvider = ((SCAClient)node).getService(Trips.class,
- "TripProvider/Trips");
-
- System.out.println("Trip boooking code = " +
- tripProvider.checkAvailability("FS1APR4", 2));
+ Trips tripProvider = ((SCAClient)node).getService(Trips.class, "TripProvider/Trips");
+
+ System.out.println("Trip boooking code = " + tripProvider.checkAvailability("FS1APR4", 2));
node.stop();
}
diff --git a/sandbox/travelsample/launchers/jumpstart/src/test/java/scatours/JumpstartTestCase.java b/sandbox/travelsample/launchers/jumpstart/src/test/java/scatours/JumpstartTestCase.java index 5ed8942168..4da7c54917 100644 --- a/sandbox/travelsample/launchers/jumpstart/src/test/java/scatours/JumpstartTestCase.java +++ b/sandbox/travelsample/launchers/jumpstart/src/test/java/scatours/JumpstartTestCase.java @@ -35,16 +35,18 @@ public class JumpstartTestCase { @Before
public void startServer() throws Exception {
- node = SCANodeFactory.newInstance().createSCANode("trips.composite",
- new SCAContribution("introducing-trips", "../../contributions/introducing-trips/target/classes"));
+ node =
+ SCANodeFactory.newInstance()
+ .createSCANode("trips.composite",
+ new SCAContribution("introducing-trips",
+ "../../contributions/introducing-trips/target/classes"));
node.start();
}
@Test
public void testClient() throws Exception {
Trips tripProvider = ((SCAClient)node).getService(Trips.class, "TripProvider/Trips");
- System.out.println("Trip boooking code = " +
- tripProvider.checkAvailability("FS1APR4", 2));
+ System.out.println("Trip boooking code = " + tripProvider.checkAvailability("FS1APR4", 2));
}
@After
diff --git a/sandbox/travelsample/launchers/notification-corba/src/main/java/scatours/NotificationCORBALauncher.java b/sandbox/travelsample/launchers/notification-corba/src/main/java/scatours/NotificationCORBALauncher.java index eb7d12f2f9..44b94b3a59 100644 --- a/sandbox/travelsample/launchers/notification-corba/src/main/java/scatours/NotificationCORBALauncher.java +++ b/sandbox/travelsample/launchers/notification-corba/src/main/java/scatours/NotificationCORBALauncher.java @@ -31,18 +31,17 @@ import scatours.notification.Notification; public class NotificationCORBALauncher {
public static void main(String[] args) throws Exception {
- SCAContribution notificationContribution =
- locate("notification");
- SCAContribution notificationCORBAContribution =
- locate("notification-corba");
+ SCAContribution notificationContribution = locate("notification");
+ SCAContribution notificationCORBAContribution = locate("notification-corba");
- SCANode node = SCANodeFactory.newInstance().createSCANode(
- "notification-corba.composite", notificationContribution, notificationCORBAContribution);
+ SCANode node =
+ SCANodeFactory.newInstance().createSCANode("notification-corba.composite",
+ notificationContribution,
+ notificationCORBAContribution);
node.start();
System.out.println("Quick notification test");
- Notification notification = ((SCAClient)node).getService(
- Notification.class, "Notification");
+ Notification notification = ((SCAClient)node).getService(Notification.class, "Notification");
String accountID = "1234";
String subject = "Holiday payment taken";
String message = "Payment of £102.37 accepted...";
diff --git a/sandbox/travelsample/launchers/notification-corba/src/main/java/scatours/notification/Notification.java b/sandbox/travelsample/launchers/notification-corba/src/main/java/scatours/notification/Notification.java index 79706fcc9d..020e1e40db 100644 --- a/sandbox/travelsample/launchers/notification-corba/src/main/java/scatours/notification/Notification.java +++ b/sandbox/travelsample/launchers/notification-corba/src/main/java/scatours/notification/Notification.java @@ -20,7 +20,7 @@ package scatours.notification; public interface Notification { - - boolean notify(String accountID, String subject, String message); + + boolean notify(String accountID, String subject, String message); } diff --git a/sandbox/travelsample/launchers/notification-ejb/src/main/java/scatours/NotificationEJBLauncher.java b/sandbox/travelsample/launchers/notification-ejb/src/main/java/scatours/NotificationEJBLauncher.java index 880908a7a7..2d843e9ff9 100644 --- a/sandbox/travelsample/launchers/notification-ejb/src/main/java/scatours/NotificationEJBLauncher.java +++ b/sandbox/travelsample/launchers/notification-ejb/src/main/java/scatours/NotificationEJBLauncher.java @@ -36,18 +36,17 @@ public class NotificationEJBLauncher { System.setProperty(Context.INITIAL_CONTEXT_FACTORY, "org.apache.openejb.client.RemoteInitialContextFactory");
System.setProperty(Context.PROVIDER_URL, "ejbd://localhost:4201");
- SCAContribution notificationContribution =
- locate("notification");
- SCAContribution notificationEJBContribution =
- locate("notification-ejb");
+ SCAContribution notificationContribution = locate("notification");
+ SCAContribution notificationEJBContribution = locate("notification-ejb");
- SCANode node = SCANodeFactory.newInstance().createSCANode(
- "notification-ejb.composite", notificationContribution, notificationEJBContribution);
+ SCANode node =
+ SCANodeFactory.newInstance().createSCANode("notification-ejb.composite",
+ notificationContribution,
+ notificationEJBContribution);
node.start();
System.out.println("Quick notification test");
- Notification notification = ((SCAClient)node).getService(
- Notification.class, "Notification");
+ Notification notification = ((SCAClient)node).getService(Notification.class, "Notification");
String accountID = "1234";
String subject = "Holiday payment taken";
String message = "Payment of £102.37 accepted...";
diff --git a/sandbox/travelsample/launchers/notification-ejb/src/main/java/scatours/notification/Notification.java b/sandbox/travelsample/launchers/notification-ejb/src/main/java/scatours/notification/Notification.java index 79706fcc9d..020e1e40db 100644 --- a/sandbox/travelsample/launchers/notification-ejb/src/main/java/scatours/notification/Notification.java +++ b/sandbox/travelsample/launchers/notification-ejb/src/main/java/scatours/notification/Notification.java @@ -20,7 +20,7 @@ package scatours.notification; public interface Notification { - - boolean notify(String accountID, String subject, String message); + + boolean notify(String accountID, String subject, String message); } diff --git a/sandbox/travelsample/launchers/notification-jms/src/main/java/scatours/JMSBrokerLauncher.java b/sandbox/travelsample/launchers/notification-jms/src/main/java/scatours/JMSBrokerLauncher.java index 7d063ca865..929eb78431 100644 --- a/sandbox/travelsample/launchers/notification-jms/src/main/java/scatours/JMSBrokerLauncher.java +++ b/sandbox/travelsample/launchers/notification-jms/src/main/java/scatours/JMSBrokerLauncher.java @@ -23,16 +23,16 @@ 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(); + 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(); + System.out.println("JMS Message Broker started"); + System.out.println("Press enter to shutdown."); + System.in.read(); - jmsBroker.stop(); + jmsBroker.stop(); } - } +} diff --git a/sandbox/travelsample/launchers/notification-jms/src/main/java/scatours/NotificationJMSLauncher.java b/sandbox/travelsample/launchers/notification-jms/src/main/java/scatours/NotificationJMSLauncher.java index c6ee50e2e8..c2ffda0725 100644 --- a/sandbox/travelsample/launchers/notification-jms/src/main/java/scatours/NotificationJMSLauncher.java +++ b/sandbox/travelsample/launchers/notification-jms/src/main/java/scatours/NotificationJMSLauncher.java @@ -31,20 +31,19 @@ import scatours.notification.Notification; public class NotificationJMSLauncher {
public static void main(String[] args) throws Exception {
- SCAContribution notificationContribution =
- locate("notification");
- SCAContribution notificationJMSContribution =
- locate("notification-jms");
+ SCAContribution notificationContribution = locate("notification");
+ SCAContribution notificationJMSContribution = locate("notification-jms");
- SCANode node = SCANodeFactory.newInstance().createSCANode(
- "notification-jms.composite", notificationContribution, notificationJMSContribution);
+ SCANode node =
+ SCANodeFactory.newInstance().createSCANode("notification-jms.composite",
+ notificationContribution,
+ notificationJMSContribution);
try {
node.start();
-
+
System.out.println("Quick notification test");
- Notification notification = ((SCAClient)node).getService(
- Notification.class, "Notification");
+ Notification notification = ((SCAClient)node).getService(Notification.class, "Notification");
String accountID = "1234";
String subject = "Holiday payment taken";
String message = "Payment of £102.37 accepted...";
diff --git a/sandbox/travelsample/launchers/notification-jms/src/main/java/scatours/notification/Notification.java b/sandbox/travelsample/launchers/notification-jms/src/main/java/scatours/notification/Notification.java index 79706fcc9d..020e1e40db 100644 --- a/sandbox/travelsample/launchers/notification-jms/src/main/java/scatours/notification/Notification.java +++ b/sandbox/travelsample/launchers/notification-jms/src/main/java/scatours/notification/Notification.java @@ -20,7 +20,7 @@ package scatours.notification; public interface Notification { - - boolean notify(String accountID, String subject, String message); + + boolean notify(String accountID, String subject, String message); } diff --git a/sandbox/travelsample/launchers/notification-rmi/src/main/java/scatours/NotificationRMILauncher.java b/sandbox/travelsample/launchers/notification-rmi/src/main/java/scatours/NotificationRMILauncher.java index 200f870417..2904349a49 100644 --- a/sandbox/travelsample/launchers/notification-rmi/src/main/java/scatours/NotificationRMILauncher.java +++ b/sandbox/travelsample/launchers/notification-rmi/src/main/java/scatours/NotificationRMILauncher.java @@ -31,18 +31,17 @@ import scatours.notification.Notification; public class NotificationRMILauncher {
public static void main(String[] args) throws Exception {
- SCAContribution notificationContribution =
- locate("notification");
- SCAContribution notificationRMIContribution =
- locate("notification-rmi");
+ SCAContribution notificationContribution = locate("notification");
+ SCAContribution notificationRMIContribution = locate("notification-rmi");
- SCANode node = SCANodeFactory.newInstance().createSCANode(
- "notification-rmi.composite", notificationContribution, notificationRMIContribution);
+ SCANode node =
+ SCANodeFactory.newInstance().createSCANode("notification-rmi.composite",
+ notificationContribution,
+ notificationRMIContribution);
node.start();
System.out.println("Quick notification test");
- Notification notification = ((SCAClient)node).getService(
- Notification.class, "Notification");
+ Notification notification = ((SCAClient)node).getService(Notification.class, "Notification");
String accountID = "1234";
String subject = "Holiday payment taken";
String message = "Payment of £102.37 accepted...";
diff --git a/sandbox/travelsample/launchers/notification-rmi/src/main/java/scatours/notification/Notification.java b/sandbox/travelsample/launchers/notification-rmi/src/main/java/scatours/notification/Notification.java index 79706fcc9d..020e1e40db 100644 --- a/sandbox/travelsample/launchers/notification-rmi/src/main/java/scatours/notification/Notification.java +++ b/sandbox/travelsample/launchers/notification-rmi/src/main/java/scatours/notification/Notification.java @@ -20,7 +20,7 @@ package scatours.notification; public interface Notification { - - boolean notify(String accountID, String subject, String message); + + boolean notify(String accountID, String subject, String message); } diff --git a/sandbox/travelsample/launchers/notification-ws/src/main/java/scatours/NotificationWSLauncher.java b/sandbox/travelsample/launchers/notification-ws/src/main/java/scatours/NotificationWSLauncher.java index 4d7f1741fe..fbdb1500f5 100644 --- a/sandbox/travelsample/launchers/notification-ws/src/main/java/scatours/NotificationWSLauncher.java +++ b/sandbox/travelsample/launchers/notification-ws/src/main/java/scatours/NotificationWSLauncher.java @@ -31,18 +31,17 @@ import scatours.notification.Notification; public class NotificationWSLauncher {
public static void main(String[] args) throws Exception {
- SCAContribution notificationContribution =
- locate("notification");
- SCAContribution notificationWSContribution =
- locate("notification-ws");
+ SCAContribution notificationContribution = locate("notification");
+ SCAContribution notificationWSContribution = locate("notification-ws");
- SCANode node = SCANodeFactory.newInstance().createSCANode(
- "notification-ws.composite", notificationContribution, notificationWSContribution);
+ SCANode node =
+ SCANodeFactory.newInstance().createSCANode("notification-ws.composite",
+ notificationContribution,
+ notificationWSContribution);
node.start();
System.out.println("Quick notification test");
- Notification notification = ((SCAClient)node).getService(
- Notification.class, "Notification");
+ Notification notification = ((SCAClient)node).getService(Notification.class, "Notification");
String accountID = "1234";
String subject = "Holiday payment taken";
String message = "Payment of £102.37 accepted...";
diff --git a/sandbox/travelsample/launchers/notification-ws/src/main/java/scatours/notification/Notification.java b/sandbox/travelsample/launchers/notification-ws/src/main/java/scatours/notification/Notification.java index 79706fcc9d..020e1e40db 100644 --- a/sandbox/travelsample/launchers/notification-ws/src/main/java/scatours/notification/Notification.java +++ b/sandbox/travelsample/launchers/notification-ws/src/main/java/scatours/notification/Notification.java @@ -20,7 +20,7 @@ package scatours.notification; public interface Notification { - - boolean notify(String accountID, String subject, String message); + + boolean notify(String accountID, String subject, String message); } diff --git a/sandbox/travelsample/launchers/policy/src/main/java/scatours/PolicyLauncher.java b/sandbox/travelsample/launchers/policy/src/main/java/scatours/PolicyLauncher.java index 838b9d93e5..4e16b9c072 100644 --- a/sandbox/travelsample/launchers/policy/src/main/java/scatours/PolicyLauncher.java +++ b/sandbox/travelsample/launchers/policy/src/main/java/scatours/PolicyLauncher.java @@ -28,20 +28,17 @@ import org.apache.tuscany.sca.node.SCANodeFactory; public class PolicyLauncher { public static void main(String[] args) throws Exception { - SCANode node1 = SCANodeFactory.newInstance().createSCANode(null, - locate("client"), - locate("payment")); + SCANode node1 = SCANodeFactory.newInstance().createSCANode(null, locate("client"), locate("payment")); node1.start(); - - SCANode node2 = SCANodeFactory.newInstance().createSCANode(null, - locate("creditcard")); - + + SCANode node2 = SCANodeFactory.newInstance().createSCANode(null, locate("creditcard")); + node2.start(); - + Runnable client = ((SCAClient)node1).getService(Runnable.class, "TestClient/Runnable"); client.run(); - + node1.stop(); node2.stop(); } |