文档章节

mq消息发送

R
 Refresh-LV
发布于 2017/08/21 23:17
字数 157
阅读 4
收藏 0

------------------------------------------controller----------------------------------------

@RequestMapping(value="productPrice/validateProductPromotionPrice" , method = RequestMethod.POST)
    public BaseResult regCouponMessage(@RequestBody ProductPriceCheckSearchDTO productPriceCheckSearchDTO) {
        AssertUtils.notNull(productPriceCheckSearchDTO,"产品价格检查对象不存在");
        jmsMessagingTemplate.convertAndSend(yjp_productpricecheck_Issue, productPriceCheckSearchDTO);
        LOG.info("产品价格检查异步请求中");
        return BaseResult.getSuccessResult();
    }
    
    @RequestMapping(value="signIn/persistence" , method = RequestMethod.GET)
    public BaseResult signInPersistence() {
        LOG.info("签到活动历史记录消息");
        jmsMessagingTemplate.convertAndSend(signPersistent,Object.class);
        return BaseResult.getSuccessResult();
    }

-----------------------------------修改后-----------------------------------------------

@RequestMapping(value = "productPrice/validateProductPromotionPrice/{cityId}", method = RequestMethod.POST)
    public BaseResult regCouponMessage(@PathVariable("cityId") Integer cityId) {
        LOG.info("产品价格检查异步请求中");
        cityId = ObjectUtils.defaultIfNull(cityId,0);
        redisTemplate.boundValueOps("createTimeRedis" + cityId).set(new Date());
        jmsMessagingTemplate.convertAndSend(yjp_productpricecheck_Issue, cityId);
        return BaseResult.getSuccessResult();
    }

--------------------------application.properties---------------------------------------

bonusandcouponissue.activemq.queue=${mq.env:}yjp_BonusCoupon_Issue
send.message.queue=${mq.env:}yjp_Message_SMS
spring.activemq.queue.partdelivery=${mq.env:}yjp_Order_Delivery
yjp_BonusCoupon_Issue=${mq.env:}yjp_BonusCoupon_Issue
productpricecheck.activemq.queue=${mq.env:}yjp_productpricecheck_Issue
signIn.activemq.queue=${mq.env:}yjp_signIn_activemq_queue

------------------------------------------------------------------------------------------

虽然我也不太懂原理是什么,就先仿照着学习写吧

© 著作权归作者所有

共有 人打赏支持
R
粉丝 1
博文 23
码字总数 7973
作品 0
仙桃
私信 提问
你不知道的WebSphere MQ几个特性的应用

IBM的WebSphere MQ消息中间件有很多的特性和优点,使用WebSphere MQ可以简化和优化消息通讯的应用设计。将这些技术和功能应用到客户的通讯系统之中,可以简化应用逻辑,优化系统架构,从而提...

fiercelf
2011/03/19
0
0
springboot整合mq发送消息队列

写在前面,mq简称消息队列,本文介绍的是activemq.那mq主要用在什么场景,他的作用又是什么呢? 介绍:mq称为消息中间件,语言表达不如看图. 顾名思义,mq主要还是为了提高服务器响应速度,提高客户...

zhuyuansj
2017/10/01
0
0
消息中间件IBM WebSphere MQ入门说明(下)

 MQ的通讯模式   1) 点对点通讯:点对点方式是最为传统和常见的通讯方式,它支持一对一、一对多、多对多、多对一等多种配置方式,支持树状、网状等多种拓扑结构。   2) 多点广播:MQ适...

fiercelf
2011/03/19
0
0
ActiveMQ技术入门、与Spring集成实例

近日总有些人来问我一些关于MQ的问题,我整理总结了一些,来跟大家分享一下,如有错误还希望各位大牛指正。探讨的同胞们可以加QQ群:315309006 MQ的概念中大致有这么三类对象,分别是broker、...

ehofy
2013/09/10
1K
1
IBM WebSphere MQ 系列(一)基础知识

一、中间件 中间件处于应用软件和系统软件之间,是一种以自己的复杂换取企业应用简单化的可复用的基础软件。 在中间件产生以前,应用软件直接使用操作系统、网络协议和数据库等开发,开发者不...

yzbty23
2015/12/01
136
0

没有更多内容

加载失败,请刷新页面

加载更多

如何在10分钟内设置EOS钱包和帐户?

由于SuperNode超级节点社区建立在EOS之上,我们希望引导我们的社区成员设置EOS钱包和帐户,以便充分参与我们的生态系统。 虽然设置过程可能不如其他区块链系统那么简单,但不要担心。本指南旨...

笔阁
7分钟前
0
0
8.04-Win10非U盘重装系统

注意:最好准备一个你所需版本的秘钥(不能是数字0开头的) 【所需:Win10的ISO镜像、能够解压ISO格式的解压缩工具、最好准备你所需版本的秘钥(不能是数字0开头的)】 1、创建新的文件系统为...

静以修身2025
7分钟前
0
0
Docker的架构与自制镜像的发布

一. docker 是什么 大家都知道虚拟机吧,windows 上装个 linux 虚拟机是大部分程序员的常用方案。公司生产环境大多也是虚拟机,虚拟机将物理硬件资源虚拟化,按需分配和使用,虚拟机使用起来...

程序猿拿Q
24分钟前
4
0
ubuntu下pycharm调用Hanlp实践分享

前几天看了大快的举办的大数据论坛峰会的现场直播,惊喜的是hanlp2.0版本发布。Hanlp2.0版本将会支持任意多的语种,感觉还是挺好的!不过更多关于hanlp2.0的信息,可能还需要过一段时间才能看...

左手的倒影
32分钟前
2
0
Python监控服务器实现邮件微信报警[未测试]

本文中笔者暂时实现的只有cpu和内存的监控,python可以监控许多的主机信息,网络,硬盘,机器状态等,以下是代码的实现,代码可以实现windows和linux的监控。 实验环境:Ubuntu16.04和windo...

dragon_tech
37分钟前
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部