spring整合activeMq并调试JMS - 编程入门网
作者 佚名技术
来源 NET编程
浏览
发布时间 2012-06-14
| ;http://www.springframework.org/schema/tx"
xsi:schemaLocation="
http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/sprin
g-beans-2.0.xsd
http://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx-
2.0.xsd" >
<bean id="dest" class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg value="myDest"></constructor-arg>
</bean>
<bean id="connectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory">
<property name="connectionFactory">
<bean class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616"/>
</bean>
</property>
</bean>
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory"></property>
<property name="defaultDestination" ref="dest"></property>
</bean>
<bean id="messageReceiver" class="com.bo.impl.MessageReceiver">
<property name="jmsTemplate" ref="jmsTemplate"></property>
</bean>
</beans>
3: 发送消息的类：
public class MessageSender extends JmsGatewaySupport{
public void sendTextMsg(final String msg) {
this.getJmsTemplate().send(new MessageCreator() {
// 这里创建了一个 message 对象,然后可以对该对象进行 各种属性的定义
private Message message;
public Message createMessage(Session session) throws JMSException {
message = session.createTextMessage(msg);
message.setStringProperty("JMSXUserID", "123456789"); // 消息所属的用户编码
message.setStringProperty("JMSXApp1ID", "001002"); // 消息所
属的应用程序编码
return message;
}
});
}
}
spring整合activeMq并调试JMS(3)时间:2011-11-02 未知4：接收消息的类：
public class MessageReceiver extends JmsGatewaySupport{
public void receiverTextMsg(){
TextMessage textMsg = (TextMessage)this.getJmsTemplate().receive();
try{
// 消息 header 中常有的 属性定义
System.out.println("消息编码：" + textMsg.getJMSMessageID());
System.out.println("目标对象：" + textMsg.getJMSDestination());
System.out.println("消息模式：" + textMsg.getJMSDeliveryMode()); // 消息的模式 分为
持久模式和非持久模式, 默认是 非持久的模式（2）
|
凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务，公司网站：http://www.lingzhong.cn 为了给广大客户了解更多的技术信息，本技术文章收集来源于网络,凌众科技尊重文章作者的版权，如果有涉及你的版权有必要删除你的文章，请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息，谢谢! |
你可能对下面的文章感兴趣
关于spring整合activeMq并调试JMS - 编程入门网的所有评论
