记录给需要帮助的人~
step :1 pom.xml
<spring-framework.version>3.2.3.RELEASE</spring-framework.version> <mq.version>7.5.0.3</mq.version> <dependency> <groupId>com.ibm.mq</groupId> <artifactId>com.ibm.mqjms</artifactId> <version>${mq.version}</version> </dependency> <dependency> <groupId>com.ibm.mq</groupId> <artifactId>com.ibm.mq.jmqi</artifactId> <version>${mq.version}</version> </dependency> <dependency> <groupId>com.ibm.mq</groupId> <artifactId>connector</artifactId> <version>${mq.version}</version> </dependency> <dependency> <groupId>com.ibm.mq</groupId> <artifactId>providerutil</artifactId> <version>${mq.version}</version> </dependency> <dependency> <groupId>com.ibm.mq</groupId> <artifactId>com.ibm.mq.commonservices</artifactId> <version>${mq.version}</version> </dependency> <dependency> <groupId>com.ibm.mq</groupId> <artifactId>com.ibm.mq.defaultconfig</artifactId> <version>${mq.version}</version> </dependency> <dependency> <groupId>com.ibm.mq</groupId> <artifactId>dhbcore</artifactId> <version>${mq.version}</version> </dependency> <dependency> <groupId>com.ibm.mq</groupId> <artifactId>com.ibm.mq.headers</artifactId> <version>${mq.version}</version> </dependency> <dependency> <groupId>com.ibm.mq</groupId> <artifactId>com.ibm.mq.pcf</artifactId> <version>${mq.version}</version> </dependency> <dependency> <groupId>javax.jms</groupId> <artifactId>jms-api</artifactId> <version>1.1-rev-1</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jms</artifactId> <version>${spring-framework.version}</version> </dependency>
step:2 connectionFactory , DefaultMessageListenerContainer 连接与监听
@Configuration // MQ连接信息的配置文件 @PropertySource("file:${ic.assistant.config.path}/ic-assistant.properties") public class MqConfig{ @Autowired private Environment env; /** * 连接MQ */ @Bean public ConnectionFactory connectionFactory() throws JMSException{ MQConnectionFactory cf = new MQConnectionFactory(); cf.setHostName(env.getRequiredProperty("ic.mq.host")); cf.setPort(Integer.parseInt(env.getRequiredProperty("ic.mq.port"))); cf.setQueueManager(env.getRequiredProperty("ic.mq.queue.manager")); cf.setChannel(env.getRequiredProperty("ic.mq.channel")); cf.setTransportType(1); return cf; } /** * 获得MQ方法监听器 */ @Bean public MessageListener eventListener(){ return new SynListener(); } /** * 配置连接,以及监听的序列,以及需要监听的方法 */ @Bean public DefaultMessageListenerContainer messageListenerContainer() throws JMSException{ DefaultMessageListenerContainer mc = new DefaultMessageListenerContainer(); mc.setConnectionFactory(connectionFactory()); mc.setDestinationName("queue:///"+env.getRequiredProperty("ic.mq.queue")); mc.setMessageListener(eventListener()); mc.setConcurrentConsumers(1); mc.setMaxConcurrentConsumers(2); return mc; }
step:3 实现MessageListener接口,重写onMessage方法
public class SynListener implements MessageListener { public void onMessage(Message message) { if (message instanceof TextMessage) { String msgContext; try { msgContext = ((TextMessage) message).getText(); if(msgContext.indexOf(FinalManager.SBC) >= 0){ synMsgService.saveSubc(msgContext); } else if (msgContext.indexOf(FinalManager.SBD) >= 0) { synMsgService.saveSubd(msgContext); } } catch (JMSException e) { } } } }
step:4 启动服务自动监听MQ
相关推荐
cmake-3.2.3-Linux-x86_64.tar.Z
"cmake-3.2.3-Linux-x86_64.tar" 文件是一个针对Linux 32位系统的CMake版本3.2.3的打包文件,通常以tar格式提供,方便用户下载和安装。 在Linux环境中,CMake扮演着构建系统的核心角色,它通过读取名为`CMakeLists....
cmake-3.2.3-Darwin-x86_64
cmake-3.2.3-Linux-x86_64
cmake-3.2.3-Darwin-x86_64.tar
cmake-3.2.3-Darwin-x86_64.tar.Z
core-3.2.3.v_686_R32x.jar core-3.2.3.v_686_R32x.jar
GDAL-3.2.3-cp38-cp38-win_amd64
南大通用GBase数据库GBase_Hibernate3.2.3_GA-Dialect_8.3.81.51_build50.1.jar
GDAL-3.2.3-pp37-pypy37_pp73-win_amd64
《Godot_v3.2.3-stable_mono_win64:深入理解Godot Mono构建的3D游戏引擎》 Godot_v3.2.3-stable_mono_win64_godotengine_,这个标题揭示了我们正在讨论的是Godot游戏引擎的一个特定版本,即3.2.3稳定版,它包含了...
`.whl`文件的命名通常包含Python版本和平台信息,例如`GDAL-3.2.3-cp39-cp39-win_amd64.whl`,其中`cp39`代表Python 3.9版本,`win_amd64`表示适用于Windows 64位系统。 **GDAL-3.2.3版本** GDAL-3.2.3是GDAL库的...
本文将深入解析 "Joomla_3.2.3-Stable-Full_Package" 的组成部分及其相关知识点。 1. **许可证与法律文件** - **LICENSE.txt**: 这个文件包含了 Joomla! 的许可协议,通常基于GPL(GNU General Public License)...
2. **获取合适的GDAL wheel文件**:在这种情况下,我们有一个名为"GDAL-3.2.3-cp37-cp37m-win_amd64.whl"的文件,这个文件是为Python 3.7编译的GDAL二进制包,适用于64位Windows系统。 3. **安装wheel文件**:首先,...
在标题"GDAL-3.2.3-cp38-cp38-win_amd64.zip"中,我们可以解读出以下信息: 1. 版本号:GDAL 3.2.3,这是该库的一个特定发行版,可能包含了修复的错误、新的功能或性能优化。 2. Python绑定:cp38表示这个版本是为...
《Godot Engine v3.2.3-stable_win64:开启游戏开发的新篇章》 Godot Engine,作为一款开源的游戏开发引擎,以其强大的功能、易用性以及跨平台支持而备受开发者喜爱。这款名为“Godot Engine v3.2.3-stable_win64”...
RH linux5.4 64位 系统包compat-libstdc++-33-3.2.3-61.x86_64.rpm
【小米5 TWRP 最新REC 自动解密data等 玩机必备TWRP-3.2.3-1002-XIAOMI5-CN-wzsx150-fastboot】 这个标题提到了小米5手机的TWRP(Team Win Recovery Project)最新版本的恢复环境,版本号为3.2.3-1002,针对中国...
libstdc++5.so丢失后的补丁 <br>