X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=demo%2Forg.argeo.slc.demo.manager%2Fsrc%2Ftest%2Fjava%2Forg%2Fargeo%2Fslc%2Fdemo%2Fmanager%2FJmsTesting.java;h=31122e213745af0abc901454eff4a6690cc5df6a;hb=5ca0831fd91542776d1d4a8b51e07b9982bd634e;hp=50ea47e3428502f575501b9736e32b928f10205b;hpb=237c2da124703a91c64cf0106d293f77821010e1;p=gpl%2Fargeo-slc.git diff --git a/demo/org.argeo.slc.demo.manager/src/test/java/org/argeo/slc/demo/manager/JmsTesting.java b/demo/org.argeo.slc.demo.manager/src/test/java/org/argeo/slc/demo/manager/JmsTesting.java index 50ea47e34..31122e213 100644 --- a/demo/org.argeo.slc.demo.manager/src/test/java/org/argeo/slc/demo/manager/JmsTesting.java +++ b/demo/org.argeo.slc.demo.manager/src/test/java/org/argeo/slc/demo/manager/JmsTesting.java @@ -1,16 +1,19 @@ package org.argeo.slc.demo.manager; +import java.net.URI; +import java.net.URISyntaxException; + import javax.jms.ConnectionFactory; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.Session; import javax.jms.TextMessage; +import org.apache.activemq.broker.BrokerService; +import org.apache.activemq.broker.TransportConnector; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.xbean.spring.context.ClassPathXmlApplicationContext; -import org.springframework.beans.BeansException; -import org.springframework.jms.JmsException; import org.springframework.jms.core.JmsTemplate; import org.springframework.jms.core.MessageCreator; @@ -21,10 +24,29 @@ public class JmsTesting { * @param args */ public static void main(String[] args) { +// BrokerService broker; +// try { +// broker = new BrokerService(); +// broker.setPersistent(false); +// TransportConnector transportConnector = new TransportConnector(); +// transportConnector.setUri(new URI("tcp://localhost:61616")); +// broker.addConnector(transportConnector); +// broker.start(); +// +// Thread.sleep(5000); +// } catch (URISyntaxException e1) { +// // TODO Auto-generated catch block +// e1.printStackTrace(); +// } catch (Exception e1) { +// // TODO Auto-generated catch block +// e1.printStackTrace(); +// } + ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext( - "conf/jms.xml"); + "org/argeo/slc/activemq/spring.xml"); try { + ConnectionFactory connectionFactory = (ConnectionFactory) applicationContext .getBean("slcDefault.jms.connectionFactory"); JmsTemplate jmsTemplate = new JmsTemplate(connectionFactory);