ActiveMQ 连接池工厂
package easyway.activemq.app.demo4;import java.util.Date;import javax.jms.JMSException;import javax.jms.MapMessage;import javax.jms.Message;import javax.jms.Session;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;import org.springframework.jms.core.JmsTemplate;import org.springframework.jms.core.MessageCreator;/** * 消息发送者 * @author longgangbai * */public class MessageSender {public static void main(String[] args) { ApplicationContext ctx = new ClassPathXmlApplicationContext("activemq-pool-jdbc.xml"); JmsTemplate jmsTemplate = (JmsTemplate) ctx.getBean("jmsTemplate"); jmsTemplate.send(new MessageCreator() { public Message createMessage(Session session) throws JMSException { MapMessage mm = session.createMapMessage(); mm.setLong("count", new Date().getTime()); return mm; } }); } }package easyway.activemq.app.demo4;import java.util.Date;import java.util.Map;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;import org.springframework.jms.core.JmsTemplate;/** * 消息发送者 * @author longgangbai * */public class MessageReceiver {@SuppressWarnings("unchecked")public static void main(String[] args) { ApplicationContext ctx = new ClassPathXmlApplicationContext("activemq-pool-jdbc.xml"); JmsTemplate jmsTemplate = (JmsTemplate) ctx.getBean("jmsTemplate"); while(true) { Map<String, Object> mm = (Map<String, Object>) jmsTemplate.receiveAndConvert(); System.out.println("收到消息：" + new Date((Long)mm.get("count"))); } } }?
<?xml version="1.0" encoding="UTF-8"?><beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd"> <bean id="connectionFactory" destroy-method="stop"> <property name="connectionFactory"> <ref bean="connectionFactory"/> </property> <property name="idleTimeout"> <value>2000</value> </property> <property name="maxConnections"> <value>10</value> </property> </bean> <bean id="destination" class="org.springframework.jms.core.JmsTemplate"> <property name="connectionFactory"> <ref bean="jmsFactory"/> </property> <property name="defaultDestination"> <ref bean="destination"/> </property> <property name="messageConverter"> <bean class="org.springframework.jms.support.converter.SimpleMessageConverter"/> </property> </bean></beans>
?
1 楼 maishj 2011-12-07 想请问下 org.apache.activemq.pool.PooledConnectionFactory 在哪个jar包，我想用代码方式设置，找不到这个类 2 楼 longgangbai 2011-12-10 我想用代码方式设置，找不到这个类maishj 写道想请问下 org.apache.activemq.pool.PooledConnectionFactory 在哪个jar包，我想用代码方式设置，找不到这个类