diff options
Diffstat (limited to '')
2 files changed, 14 insertions, 12 deletions
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(); } - } +} |