腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(5118)
视频
沙龙
1
回答
Spring
AMQP
-
将
消息
返
回到
队列
的
开头
、
、
、
我想知道是否有任何方法可以
将
消息
返
回到
其在
队列
中
的
原始位置。例如,假设我们有这样
的
排序: A是头部,D是尾部
的
A-B-C-D。通常,当我们
将
nack或reject与requeue=true一起使用时,它只是
将
消息
排在当前尾部之后。在这种情况下,当重新排队A时,新
的
顺序变为B-C-D-A。然而,我想知道是否有任何方法可以入队到
队列
的
开头
。因此,如果
浏览 12
提问于2019-07-01
得票数 0
回答已采纳
2
回答
狂犬病of与弹簧
amqp
-
消息
卡在AmqpException
的
情况下
、
、
我正在向我
的
消费者扔一个AmqpException。我
的
期望是,该
消息
将
返
回到
队列
的
FIFO顺序,并将在未来
的
某个时候被重新处理。 似乎
Spring
没有
将
消息
释放回
队列
。而是尝试一次又一次地重新处理失败
的
消息
。这将阻止新到达
的
消息
被处理。那些卡住
的
出现在
AMQP
控制台内永远处
浏览 6
提问于2015-02-06
得票数 4
回答已采纳
2
回答
什么是
Spring
AMQP
中
的
publisher退货
、
、
、
、
我一直在尝试
Spring
AMQP
。我有几个问题: 我想知道什么是出版商退货,它与出版商确认有什么不同。据我所知,我们有一个发布者确认回调来检查ack
的
状态。现在,我查看了
Spring
AMQP
和Rabbit MQ中
的
文档。在这方面并没有真正找到或理解太多。还有,为什么如果尝试
将
消息
发送到不存在
的
队列
,我既得不到任何类型的确认(ack/nack ),也得不到任何错误。对于非确认,有没有setTimeouts
浏览 0
提问于2018-05-22
得票数 4
1
回答
如何使用
Spring
AMQP
编写Apple推送通知?
、
、
我是个推送通知
的
新手。我想写一个代码使用
Spring
AMQP
将
发送通知
消息
到APN。我随身带着.p12、认证和.pem文件。谁能帮我写代码使用
Spring
AMQP
,它将发送通知
消息
。 提前谢谢。
浏览 3
提问于2013-09-06
得票数 0
3
回答
在使用
Spring
Integration和RabbitMQ时,如何在消费者端处理格式不佳
的
消息
、
、
、
我目前正在做一个项目,涉及消费来自RabbitMQ brocker
的
消息
。然而,我对
Spring
Integration、
AMQP
和RabbitMQ仍然是个新手。我在使用格式错误
的
消息
格式时遇到了问题。当我
的
消费者收到格式错误
的
消息
时,它会将其返
回到
队列
中,然后RabbitMQ将其返回,这将造成一个无尽
的
循环。在
Spring
Integration文档中,有一些可
浏览 0
提问于2015-03-24
得票数 2
1
回答
弹簧集成
amqp
通道错误处理程序
、
、
、
我有一个
amqp
支持
的
通道<int-
amqp
:channel>,可以暂时保存来自JDBC入站适配器
的
消息
。当没有异常抛出时,
消息
就会被破坏并从兔子
队列
中删除。当出现异常时,
消息
将
返
回到
队列
并继续进行重新处理。在某些情况下,我希望请求返
回到
队列
,但在大多数情况下,我只想记录错误并确认请求(从兔子
队列
中删除)。我已经实现了一个errorH
浏览 3
提问于2015-02-20
得票数 1
回答已采纳
1
回答
有没有一种方法可以通过编程
的
方式来配置铲子?
、
、
我们正在开发一个
Spring
-
AMQP
- RabbitMQ应用程序。我们希望使用shovel
将
消息
从本地
队列
复制到远程
队列
,但我们希望在
spring
应用程序中完成
消息
传递服务
的
几乎所有配置。在这一点上,我们可以从应用程序本身创建
队列
,交换等,但我们不能找到一种方法来配置同一个应用程序
的
铲子。有没有办法做到这一点?如果我们使用联邦插件而不是铲子,有没有更好
的
方法来配置它而不是使用<
浏览 1
提问于2012-12-05
得票数 0
回答已采纳
2
回答
是否有允许持久订阅和完全重播
的
消息
总线提供程序?
、
、
、
、
我试图找到一个
消息
总线提供者,它支持,并允许我根据
消息
时间戳顺序地重播给定主题
的
所有
消息
。此外,我希望
消息
总线在邮件晚到时重新设置每个持久用户
的
检查点。例如。客户在2009-12-22 12:00订阅主题1 客户端接收
消息
2,然后接收
消息
1。有人知道有
消息</em
浏览 2
提问于2009-12-22
得票数 2
1
回答
从服务总线
队列
中获取数据时出错
我正在开发一个POC来处理从客户端到服务器
的
大型数据,使用azure作为平台。但问题是当我从服务总线
队列
中获取数据时。我正在使用
的
技术栈如下: java.lang.NullPointerException at com.sun.jersey.api.client.Clien
浏览 1
提问于2016-09-05
得票数 1
1
回答
使用
Spring
AMQP
监听许多短暂
的
、动态创建
的
队列
、
、
、
我正在使用RabbitMQ/
Spring
/
Spring
AMQP
构建一个应用程序,并且在处理我
的
队列
布局时遇到了问题。从本质上讲,我有一个每个消费者都会监听
的
队列
,每个
消息
基本上都说“这个
队列
已经准备好由一个消费者来处理了”。然后,使用者
将
侦听
消息
中指示
的
队列
,使用该
队列
中
的
所有
消息
,最后在
浏览 41
提问于2019-10-02
得票数 0
回答已采纳
1
回答
SI DSL:
AMQP
队列
流定义中句柄()和通道()之间
的
区别
我已经复习了我能找到
的
文档,但还没有找到答案,所以我希望在这里得到一些启示。这两个电话有什么区别吗?.handle(
Amqp
.outboundAdapter(amqpTemplate).routingKey("my-queue")) .channel(
Amqp
.channel(connectionFactory
浏览 2
提问于2017-03-24
得票数 1
回答已采纳
1
回答
Spring
Amqp
+ RabbitMQ中基于异常
的
不同死信
队列
、
、
、
、
给定一个使用RabbitMQ
队列
中
的
消息
的
基本MessageListener实现,如何根据处理
消息
时可能抛出
的
异常类型
将
消息
发送到不同
的
死信
队列
?最初发布
消息
的
队列
上设置了x-dead-letter-exchange和x-dead-letter-routing-key,但在我
的
示例中这是不够
的
。如果重要的话,我
的</em
浏览 1
提问于2014-04-07
得票数 0
2
回答
当rabbitmq中
的
给定
队列
中没有
消息
可用时
的
使用者线程状态
、
我只是好奇当没有数据发布到消费者所链接
的
队列
时
的
消费者状态 @Component } catch (Exception e) { }} 任何解释这一点
的
链接都是更有用
的
浏览 24
提问于2021-04-12
得票数 0
1
回答
Spring
批处理ItemReader + RabbitMQ -没有指定“
队列
”
、
、
、
、
我正在运行两个服务:一个连接到DB并向msg发送数据,另一个应该接收来自兔子
的
消息
并通过批处理发送到targetDB。我在每个服务中都有相同
的
RabbitConfiguration,但出于某种原因,我得到了: org.springframework.
amqp
.AmqpIllegalStateException: Noat org.springframework.
amqp
.rabbit.core.RabbitTemplate.getRequiredQueue(RabbitTemplate.java:2410
浏览 1
提问于2020-03-01
得票数 1
回答已采纳
1
回答
减慢入站通道
、
我们使用
spring
集成
将
消息
从一个代理(
amqp
\ jms)传输到另一个代理。我们希望减缓来自输入通道
的
消息
的
消耗:<int-
amqp
: inbound-channel-adapter>或<int-jms: message-driven-channel-adapter (例如,通过添加一个速度),以避免使远程
队列
饱和,从而给它处理
消息
的
时间。另一个约束是尊重输出
队列</
浏览 8
提问于2020-12-22
得票数 0
1
回答
在
Spring
AMQP
中监视“强制”
消息
从1.5 ()开始,我就一直在使用
Spring
AMQP
对“强制”
消息
的
实现。现在,我想为了一些目的“监视”这些
消息
,但似乎除了接收这些
消息
的
预期消费者之外,我不能真的让其他人接收这些
消息
(因为这将被算作传递,因此发送者将不会被通知)。我是否有其他选择(由RabbitMQ本身或
Spring
AMQP
提供)来
将
这些
消息
“复制”到另一个
队列
,而不会影响弹性公网I (S
浏览 0
提问于2015-10-08
得票数 1
1
回答
使用
spring
集成在Exchange中动态选择RabbitMq
队列
、
、
、
、
从生产者,我必须发送
消息
到RabbitMQ交换。此
消息
将
包含特定属性,例如
队列
名,根据此属性,我必须动态决定发送此message.queue
的
队列
,以绑定exchange,以发送此特定
消息
。有没有办法截获到达RabbitMQ交换
的
消息
,使用
spring
集成,目前,我有以下
spring
集成配置文件。我不知道如何创建一个bean来获取交换
消息
,并将
消息
路由到smsQu
浏览 1
提问于2013-07-21
得票数 0
回答已采纳
2
回答
为什么CELERY_ROUTES同时有“
队列
”和"routing_key"?
、
、
我对
AMQP
的
理解是,
消息
只包含以下组件: 在芹菜中,推荐
的
路由任务方式是通过CELERY_ROUTES设置。从医生那里,CELERY_ROUTES是..。用于
将
任务路由到
队列
的</em
浏览 6
提问于2015-04-22
得票数 44
2
回答
在Mule上监听
队列
,处理信息并发送回
、
、
我构建
spring
应用程序并将其发送到RabbitMQ。现在我想在Mule ESB中建立项目,侦听
队列
并处理信息,如果有变量a(例如) ->流程到aa流程等,->
将
响应转换为JSON ->发送回RabbitMQ。-我看过一些例子,但不能完美地理解这个主题。`* </
amqp
:queue-profile> -->
浏览 0
提问于2015-05-04
得票数 0
5
回答
RabbitMQ -清除
队列
中所有未确认
的
消息
我
的
开发环境中有数以千计
的
未确认
消息
,我无法重新启动。 有没有一种方法可以删除(清除)所有
消息
,即使它们是未确认
的
?
浏览 210
提问于2014-08-04
得票数 48
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
第八篇:SpringBoot 整合 rabbitmq
SpringBoot 第十二章:RabbitMQ 集成使用
RabbitMQ实战:运行和管理RabbitMQ
什么是 Azure 服务总线?
消息队列中间件(二)使用 ActiveMQ
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券