文档章节

mq消息发送

R
 Refresh-LV
发布于 2017/08/21 23:17
字数 157
阅读 3
收藏 0
点赞 0
评论 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
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
springboot集成activeMQ实现消息队列监听以及实现MQ延迟

1.简介 1.1 什么是ActiveMQ ActiveMQ 是 Apache 出品,最流行的,能力强劲的开源消息总线。ActiveMQ 是一个 完全支持 JMS1.1 和 J2EE 1.4 规范的 JMS Provider 实现,尽管 JMS 规范出台已经是...

beyondLi71的博客
2017/12/22
0
0
posix消息队列概述以及限制

消息队列可以当做一个消息链表,不同于FIFO和管道,某个进程往一个消息队列写入消息之前,不需要另外进程在该队列上等待消息的到达。 对posix消息队列的读总是返回最高优先级的最早消息。 常...

chengyang
2011/09/19
0
0
IBM WebSphere MQ 系列(三)配置和使用WebSphere MQ

配置和使用WebSphere MQ A.设置环境变量 在shell中执行MQ的控制命令: ctrmqm strmqm 若识别这些命令,则说明PATH环境变量已配置好了; 若提示找不到命令,则说明需配置Linux环境变量,指定M...

yzbty23
2015/12/01
174
0
分布式事务之rabbitmq肉身实战

本文对比 二阶段事务、最大努力交付以及消息最终一致性,并给出部分解决方案,最终一致性方案参考阿里RockMQ事务消息:http://blog.csdn.net/chunlongyu/article/details/53844393) image.pn...

方老司
2017/12/11
0
0
ZBus简单介绍

HTTP兼容 ZBus的通信协议头是采用HTTP格式头,而Body部分可以是任意的格式。 这样子在流量器访问和Broke建立链接是一致的接口 MQ / TOPIC ZBus 支持MQ 和 Topic,默认为MQ类型。 Producer/C...

精通吹水
2016/04/08
582
0
【IPC通信】Posix消息队列使用异步事件通知

mq_notify()函数为指定队列建立或删除异步事件通知,建立通知即某空消息队列中如有新的消息,会发送一个信号或创建一个线程来执行指定的函数。 #include <mqueue.h>int mqnotify(mqdt mqdes...

恋恋美食
2011/11/18
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

前端基础

1. get请求传参长度的误区 误区:我们经常说get请求参数的大小存在限制,而post请求的参数大小是无限制的。 实际上HTTP 协议从未规定 GET/POST 的请求长度限制是多少。对get请求参数的限制是...

wenxingjun
今天
0
0
Android 复制和粘贴功能

做了一回搬运工,原文地址:https://blog.csdn.net/kennethyo/article/details/76602765 Android 复制和粘贴功能,需要调用系统服务ClipboardManager来实现。 ClipboardManager mClipboardM...

她叫我小渝
今天
0
0
拦截SQLSERVER的SSL加密通道替换传输过程中的用户名密码实现运维审计(一)

工作准备 •一台SQLSERVER 2005/SQLSERVER 2008服务 •SQLSERVER jdbc驱动程序 •Java开发环境eclipse + jdk1.8 •java反编译工具JD-Core 反编译JDBC分析SQLSERVER客户端与服务器通信原理 SQ...

紅顏為君笑
今天
6
0
jQuery零基础入门——(六)修改DOM结构

《jQuery零基础入门》系列博文是在廖雪峰老师的博文基础上,可能补充了个人的理解和日常遇到的点,用我的理解表述出来,主干出处来自廖雪峰老师的技术分享。 在《零基础入门JavaScript》的时...

JandenMa
今天
0
0
linux mint 1.9 qq 安装

转: https://www.jianshu.com/p/cdc3d03c144d 1. 下载 qq 轻聊版,可在百度搜索后下载 QQ7.9Light.exe 2. 去wine的官网(https://wiki.winehq.org/Ubuntu) 安装 wine . 提醒网页可以切换成中...

Canaan_
今天
0
0
PHP后台运行命令并管理运行程序

php后台运行命令并管理后台运行程序 class ProcessModel{ private $pid; private $command; private $resultToFile = ''; public function __construct($cl=false){......

colin_86
今天
1
0
数据结构与算法4

在此程序中,HighArray类中的find()方法用数据项的值作为参数传递,它的返回值决定是否找到此数据项。 insert()方法向数组下一个空位置放置一个新的数据项。一个名为nElems的字段跟踪记录着...

沉迷于编程的小菜菜
今天
1
1
fiddler安装和基本使用以及代理设置

项目需求 由于开发过程中客户端和服务器数据交互非常频繁,有时候服务端需要知道客户端调用接口传了哪些参数过来,这个时候就需要一个工具可以监听这些接口请求参数,已经接口的响应的数据,这种...

银装素裹
今天
0
0
Python分析《我不是药神》豆瓣评论

读取 Mongo 中的短评数据,进行中文分词 对分词结果取 Top50 生成词云 生成词云效果 看来网上关于 我不是药神 vs 达拉斯 的争论很热啊。关于词频统计就这些,代码中也会完成一些其它的分析任...

猫咪编程
今天
0
0
虚拟机怎么安装vmware tools

https://blog.csdn.net/tjcwt2011/article/details/72638977

AndyZhouX
昨天
1
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部