- 浏览: 414565 次
- 性别:
- 来自: 上海
文章分类
最新评论
-
IThead:
纠结了几天,用了你的方法,现在解决了,谢谢!
Eclipse 写Javascript卡死问题 -
Rubicon__:
你好,我在运用PageWidget这个类时,出现第一页翻到第二 ...
android翻书效果实现原理( 贝塞尔曲线绘制原理/点坐标计算) -
lionios:
如果不显示printDialog,则打印出来的是空白页,请问你 ...
Print打印机例子 -
rayln:
weiqiulai 写道哥们儿,我怎么没有看到监控队列的配置和 ...
JMS监听MQ实例 -
weiqiulai:
哥们儿,我怎么没有看到监控队列的配置和代码?
JMS监听MQ实例
jsm_applicationContext.xml配置
JmsManager.java配置
这个是Spring做的. xml部分就是配置了啊
<!-- 配置jms参数 --> <bean id="QmembfeQmConnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory"> <property name="queueManager"> <value>QMEMBFE</value> </property> <property name="hostName"> <value>182.119.170.83</value> </property> <property name="transportType"> <value>1</value> </property> <property name="port"> <value>1417</value> </property> <property name="CCSID"> <value>819</value> </property> <property name="channel"> <value>SYSTEM.DEF.SVRCONN</value> </property> </bean> <!-- 配置jms的发送管理队列 --> <bean id="sendQueue" class="com.ibm.mq.jms.MQQueue"> <property name="baseQueueName"> <value>3012900001_5</value> </property> <property name="targetClient"> <value type="int">1</value> </property> </bean> <!-- 配置jms的接收管理队列 --> <bean id="acceptQueue" class="com.ibm.mq.jms.MQQueue"> <property name="baseQueueName"> <value>3012900001_4</value> </property> <property name="targetClient"> <value type="int">1</value> </property> </bean> <!-- 固定配置开始 --> <bean id="jmsTransactionManager" class="org.springframework.jms.connection.JmsTransactionManager"> <property name="connectionFactory"> <ref bean="QmembfejmsConnectionFactory" /> </property> </bean> <bean id="QmembfejmsConnectionFactory" class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter"> <property name="targetConnectionFactory" ref="QmembfeQmConnectionFactory" /> <property name="username" value="" /> <property name="password" value=" " /> </bean> <bean id="txProxyTemplateJms" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean" abstract="true"> <property name="transactionManager" ref="jmsTransactionManager" /> <property name="transactionAttributes"> <props> <prop key="send*">PROPAGATION_REQUIRED</prop> <prop key="get*">PROPAGATION_REQUIRED</prop> <prop key="process*">PROPAGATION_REQUIRED</prop> </props> </property> </bean> <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate" > <property name="connectionFactory"> <ref bean="QmembfejmsConnectionFactory"/> </property> </bean> <!-- 固定配置结束 --> <bean id="jmsManager" class="com.jms.manager.JmsManager"> <property name="jmsTemplate"> <ref bean="jmsTemplate"/> </property> </bean>
JmsManager.java配置
public class JmsManager { private JmsTemplate jmsTemplate; public void sendMessage(final String msg){ BeanFactory factory = new ClassPathXmlApplicationContext("jms_applicationContext.xml"); Destination destination = (Destination)factory.getBean("sendQueue"); jmsTemplate.send(destination, new MessageCreator(){ public Message createMessage(Session session) throws JMSException { BytesMessage message = session.createBytesMessage(); try { message.writeBytes(msg.getBytes("UTF-8"); } catch (UnsupportedEncodingException e) {} return message; } }); } public byte[] getMessage(){ byte[] msg = (byte[])null; BeanFactory factory = new ClassPathXmlApplicationContext("jms_applicationContext.xml"); Destination destination = (Destination)factory.getBean("acceptQueue"); Message message = jmsTemplate.receive(destination); try{ if(message instanceof TextMessage){ msg = ((TextMessage)message).getText().getBytes(); return msg; } if(message instanceof BytesMessage){ BytesMessage bMsg = (BytesMessage)message; msg = new byte[(int)bMsg.getBodyLength()]; bMsg.readBytes(msg); return msg; } if(message instanceof ObjectMessage){ ObjectMessage oMsg = (ObjectMessage)message; msg = (byte[])oMsg.getObject(); return msg; } } catch (JMSException e) { e.printStackTrace(); } return msg; } }
评论
2 楼
rayln
2012-12-12
weiqiulai 写道
哥们儿,我怎么没有看到监控队列的配置和代码?
这个是Spring做的. xml部分就是配置了啊
1 楼
weiqiulai
2012-12-10
哥们儿,我怎么没有看到监控队列的配置和代码?
发表评论
-
乱码问题解决方法汇总
2012-01-08 18:39 10991. Spring在web.xml中设置过滤器 <fil ... -
注解注入类
2012-01-05 12:46 911请看例子: applicationContext.xml ... -
Spring-mvc+hibernate整合
2012-01-05 01:01 782转载: http://blog.csdn.net/penngo ... -
Root根路径(绝对路径)获取
2011-12-14 09:15 1107String root = System.getPropert ... -
Log4j配置文件
2011-12-05 10:39 898使用${webapp.root}配置相对路径 log4j. ... -
Spring自己控制事务
2011-10-09 17:04 885applicationContext.xml <bean ... -
Spring使用扫描注入
2011-10-09 17:04 793applicationContext.xml <cont ... -
SpringMVC使用国际化步骤
2011-10-09 17:05 929mess.properties welcome=welcome ... -
SpringMVC使用拦截器步骤
2011-10-10 12:42 1010applicationContext.xml <bean ... -
SpringMVC注释使用entity实体传输
2011-10-10 12:42 1260//Emp为实体 @RequestMapping(value ... -
SpringMVC使用classname自动映射Controller
2011-10-10 12:42 738<bean class="org.spring ... -
SpringMVC模式注解式annotation配置控制器
2011-10-10 12:42 1321Web.xml <listener> < ... -
SpringMVC模式各种配置以及各种控制器
2011-10-10 12:43 1483Web.xml <listener> < ... -
Tomcat与Spring的连接池整合问题
2011-10-11 09:14 709PS:注意需要把driver包放到tomcat/lib/下面 -
Spring定时器
2011-10-11 09:14 790两个类: public class Test1 extends ... -
如何用Spring建立MVC模式
2011-10-11 09:15 951web.xml配置 <context-param> ... -
Marshaller和Unmarshaller用法
2011-10-11 09:15 3317application_marshaller配置 <be ... -
如何把iBatis注入到Spring中
2011-10-12 08:33 1019application.xml配置: <bean id= ... -
使用jndi连接池和Tomcat与Spring连接池使用指南
2011-10-12 08:33 1507<jee:jndi-lookup id="my ... -
把hibernate注入到spring中
2011-10-12 08:34 779<bean id="myDataSource& ...
相关推荐
NULL 博文链接:https://qiaokeli.iteye.com/blog/1782656
MQ的命令集合 JMS 获取MQ队列信息 JSM 发送信息至MQ
用jms 向webshpere mq里发送消息
MQ软件提供一个JAVA软件包,里面有JMS类库,和一套MQ的类库。不熟悉MQI编程方法的程序员可以用JMS,比较熟悉MQI编程方法的程序则可以用MQ类库来编程。下面的小程序是使用Java实现从队列管理器QM_SERVER中的队列INITQ...
JMS 操作IBM MQ,实现订阅发布模式!包含完整的JAR包以及测试文件。
Spring Boot + RWD + JMS/MQ
Spring + JMS + MQ Connection
JMS_MQ系统之Spring中嵌入ActiveMQ,JMS_MQ系统之Spring中嵌入ActiveMQ
目的:通过JMS 实现 IBM MQ的请求应答功能 工作原理:消息生产者发送消息到队列IN1,然后可以异步或者同步等待消费者接收到IN1消息后,生成应答消息,并发布到IN2队列中。生产者通过messageid在IN2队列中进行消息...
1) 本工程主要演示在SPRING BOOT工程中怎样使用JMS集成IBM-MQ及TLQ两种消息中间件产品 2) 使用SPRING BOOT Conditional机制实现了两种产品按需加载,工程会根据配置文件开关动态加载 3) 实现了普通队列消息发送与...
JMS经典实例 , 基于weblogic 服务器,
JMS如何整合Spring,简单实例,仅供参考
本电子书详细介绍了jms ,mq 的java编程,希望对有需要的朋友有所帮助。
三个jms的实例,实现了jms的queue和topic,同时也实现了远程传送消息和本地传送消息,另外也分别实现了session的事务和非事务模式,有了这三个例子应该可以满足你的任何关于jms的需求了,由于上传限制,另外还需要...
一般MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法。
含有八个独立运行的程序,分别设计JMS多个方面。 工程使用ActiveMQ,运行工程之前,请阅读doc.txt文档,并运行ActiveMQ
activemq与spring整合发送jms消息入门实例 jar 包和实例代码都在压缩包里了
JMS (JAVA Message Server)信息传输实例代码。消息发送端,消息接收端。进行异步同步通讯,代码易懂,对于初学JMS者会有很大的帮助!
该例子是本人写的一个关于使用springMVC搭建的activeMQ的JSM实例,希望对学校JMS的朋友有所帮助。
jms应用的一个实例,相信对学习有用!!!!1