文档章节

mq消息发送

R
 Refresh-LV
发布于 2017/08/21 23:17
字数 157
阅读 3
收藏 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 系列(一)基础知识

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

yzbty23
2015/12/01
136
0
消息中间件IBM WebSphere MQ入门说明(下)

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

fiercelf
2011/03/19
0
0
消息中间件IBM WebSphere MQ入门说明(中)

 MQ的基本概念   1) 队列管理器   队列管理器是MQ系统中最上层的一个概念,由它为我们提供基于队列的消息服务。   2) 消息   在MQ中,我们把应用程序交由MQ传输的数据定义为消息,...

fiercelf
2011/03/19
0
0

没有更多内容

加载失败,请刷新页面

加载更多

Kafka如何做到1秒处理1500万条消息?

Apache Kafka 是一款流行的分布式数据流平台,它已经广泛地被诸如 New Relic(数据智能平台)、Uber、Square(移动支付公司)等大型公司用来构建可扩展的、高吞吐量的、且高可靠的实时数据流系统...

架构师springboot
27分钟前
7
0
如何清理Nexus Repository Manager

随着开发运维一体化的理念逐渐深入,持续集成流水线已经成为软件开发的标配。持续集成通过高度自动化的方式,使得构建发布变得非常简单,构建发布次数随之变的越来越多。我们在享受高频次的构...

JasonSE
40分钟前
1
0
聊聊storm的ack机制

序 本文主要研究一下storm的ack机制 实例 SentenceSpout public class AckSentenceSpout extends BaseRichSpout { private ConcurrentHashMap<UUID, Values> pending; private Spo......

go4it
49分钟前
1
0
《netty入门与实战》笔记-05:netty内置的channelHandler

Netty 内置了很多开箱即用的 ChannelHandler。下面,我们通过学习 Netty 内置的 ChannelHandler 来逐步构建我们的 pipeline。 ChannelInboundHandlerAdapter 与 ChannelOutboundHandlerAdap...

Funcy1122
今天
3
0
帧动画(wifi信号动态动画)

准备六张wifi不同信号强度的素材图片,复制到drawable目录中 在drawable目录中新建frame文件,并编写代码 <animation-list xmlns:android="http://schemas.android.com/apk/res/android"> ...

lanyu96
今天
5
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部