给RabbitMQ发送消息时,设置请求头Header。

消费者

由于消费者那里,@Payload是接受的消息体,使用了@Header注解,需要请求头,生产者这边就要设置,如下代码:

这是RabbitTemplate中的converAndSend(exchang,routingKey,消息体,消息头)方法。

@Override
    public void convertAndSend(String exchange, String routingKey, final Object message,
            final MessagePostProcessor messagePostProcessor) throws AmqpException {
        convertAndSend(exchange, routingKey, message, messagePostProcessor, null);
    }

原文地址:https://www.cnblogs.com/theRhyme/p/9724091.html

时间: 2024-11-10 13:13:16

给RabbitMQ发送消息时,设置请求头Header。的相关文章

OSS上传文件时设置请求头

直接上传: // 如果需要上传时设置存储类型与访问权限,请参考以下示例代码. // ObjectMetadata metadata = new ObjectMetadata(); // metadata.setHeader(OSSHeaders.OSS_STORAGE_CLASS, StorageClass.Standard.toString()); // metadata.setObjectAcl(CannedAccessControlList.Private); // putObjectRe

jquery ajax 设置请求头header 参数

$.ajax( { url:'http://127.0.0.1:30080/api-a/quasiCustom/selectCustomList', type:'post', dateType:'json', beforeSend: function(xhr) { xhr.setRequestHeader("organId:'1333333333'"); }, headers:{'Content-Type':'application/json;charset=utf8','organI

设置请求头信息的不同方式

原文:http://blog.csdn.net/magiclr/article/details/49643277 在AngularJs中有三种方式可以设置请求头信息: 1.在http服务的在服务端发送请求时,也就是调用http()方法时,在config对象中设置请求头信息: $http.post('/somePath' , someData , { headers : {'Authorization' : authToken} }).success(function(data, status,

axios设置请求头失效的问题

前言:因为在使用vue-element-admin框架时遇到了设置请求头失效的问题,在后来发现是代理跨域问题,所以又简单理解了一下跨域. 出现的问题是我在axios拦截器上设置了请求头token,但是在发送请求时并未携带token, 经过原因排查, 发现我在请求路径时直接设置为服务器环境域名,改为localhost,并通过proxy代理后成功设置了请求头token. 首先,了解什么是跨域? 当一个请求url的协议.域名.端口三者之间任意一个与当前页面url不同即为跨域. 我们常见的跨域场景: U

JavaScript之ajax的作用、流程以及如何设置请求头

什么是ajax?它的作用是什么?它的流程好处又有那些?如何设置请求头呢????????(嘻嘻,不知道请往下看哦): 1)什么是ajax呢? ajax即"Asynchronous Javascript And XML"(异步的JavaScript和xml),是指一种创建交互式网页应用的网页开发技术. 2)ajax的作用又是什么呢? 通过在后台与服务器进行少量数据交换,Ajax 可以使网页实现异步更新.这意味着可以在不重新加载整个网页的情况下,对网页的某部分进行更新. 通俗的来讲:它是一种

AFN Post方法 设置请求头(json)

设置请求头:[manager.requestSerializer setValue:@"application/json" forHTTPHeaderField:@"Content-Type"]; GET方法设置请求头的时候没什么问题:但是使用POST方法时设置无效,使用其他方法都没用,后来发现没有序列化 manager.requestSerializer = [AFJSONRequestSerializer serializer]; 注意: 和manager.re

ajax中的setRequestHeader设置请求头

1.问题引发点: 前不久发现一个问题: 前端并没有设置请求头信息里面的Accept-Encoding:gzip...但是在请求头中可以明显的看到Accept-Encoding:gzip, deflate, sdch,并且我尝试修改这个请求头,发现 不 生 效: 2.XMLHttpRequest对象提供了一个设置请求头的方法:setRequestHeader,对应的jQuery可以再beforeSend回调里面设置请求头: $.ajax({ type: "GET", url: "

解决Handler发送消息时:this message is already in use

为了避免在主线程中进行耗时操作,我们经常使用handler来发送消息处理耗时操作. 有时候会出现程序崩溃然后控制台显示this message is already in use的报错信息 报错的信息是指:发送的message正在消息队列中,不能被使用. 其实就是当我们想多次发送消息时,不能使用同一个消息的意思,所以解决的方法就是再次发送的时候重新获取一个新的消息. 注: 不推荐直接使用Message的构造方法创建对象,而是应该通过Message类的静态方法obtain()获取消息对象,该方法会

设置请求头解决浏览器同源问题

思想: 添加过滤器 设置请求头 代码如下 package com.deppon.vas.common.framework.cors; import java.io.IOException; import javax.servlet.Filter; import javax.servlet.FilterChain; import javax.servlet.FilterConfig; import javax.servlet.ServletException; import javax.servl