腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Spring
jms
在
处理
和
确认
之前
将
消息
缓冲
成批处理
。
、
、
我正在寻找一个如何使用
Spring
jms
实现以下内容的示例。 我的应用程序从队列接收
消息
,经过一些
处理
后,
将
结果发送到web服务。该web服务现在支持批量
消息
,我们想开始使用它。The Client AcknowledgmentMode似乎是其中的一部分,但我还不明白我们如何防止
消息
堆积在应用程序的内存中。如果批量api请求或导致该请求的任何
消息
的任何
处理
失败,则必须回滚所有
jms
消息
。
浏览 15
提问于2019-10-07
得票数 0
1
回答
Spring
Integration
JMS
事务错误通道事务
、
我目前
在
Spring
集成中遇到了
JMS
事务方面的困难。我创建的集成流程如下所示:我希望
在
JMS
队列B
和
JMS
队列C上保证
消息
的传递。但是,为了稍微增加难度,我希望
将
导致错误的
消息
存储
在
单独的JMQ队列中,并
确认
队列A上的
消息<
浏览 0
提问于2015-07-15
得票数 1
1
回答
spring
jms
监听器
将
acknowadge类型更改为非自动
、
、
好的,我使用的是
spring
jms
listener,而目前我使用的是默认的
确认
类型- auto,所以
在
导入/
处理
ti
之前
,
消息
就会被使用。如何将此类型更改为以后使用此侦听器可以
在
处理
和
删除此
消息
时手动
确认
的类型
浏览 4
提问于2012-07-17
得票数 0
2
回答
Spring
同步Hibernate
和
JMS
事务
、
、
、
、
我正在开发一个同时使用
JMS
和
Hibernate的独立应用程序。 文档建议,如果我想跨两个资源进行事务
处理
,则必须使用JTA。然而,现在有了@Transaction注解的DAO方法(
和
HibernateTransactionManager),这似乎已经起作用了。当我
在
JmsTemplate上调用send()时,
消息
不会立即发送,而是
在
方法返回时通过Hibernate会话提交。事实证明,Hibernate
和
JMS
的包装器都向Transa
浏览 0
提问于2012-05-29
得票数 6
回答已采纳
3
回答
骆驼向OracleAQ发送
消息
、
、
、
、
我们需要使用Camel
将
一个巨大的xml有效负载从activemq队列发送到oracle aq队列。那么,我们如何
将
这些巨大的有效载荷传递给Oracle。我是否必须在骆驼中设置一些东西,以便
将
消息
以“CLOB”而不是“VARCHAR”的形式传递给oracle?还是需要在甲骨文这边做些什么?
浏览 3
提问于2014-03-28
得票数 0
回答已采纳
2
回答
如何在ActiveMQ中将多条
消息
一起传递给侦听器?
、
、
我希望通过activemq
将
100条
消息
一起传递给消费者,但同时生产者
将
一次只生成一条
消息
。 我之所以想这样做,是因为我不想在传递时单独
处理
每个
消息
的开销,而是希望
在
传递时进行批量
处理
。
浏览 0
提问于2014-12-30
得票数 0
回答已采纳
1
回答
JMS
ActiveMQ使用者,何时
确认
、
、
我有一个
JMS
使用者,它执行以下操作:
在
收到
和
确认
消息
之间等待很长一段时间可以吗?
处理
消息
可能需要24小时。
在
Windows服务器上使用Java、
Spring
、ActiveMQ
和
CLIENT_ACKNOWLEDGE模式。
浏览 0
提问于2019-06-13
得票数 1
1
回答
AWS SQS
JMS
确认
、
、
、
我想跟踪并重试有异常的
消息
。所以我使用的是DUPS_OK_ACKNOWLEDGEMENT模式。在这种情况下,如果我对一条
消息
进行
确认
,它就是
确认
队列中的所有
消息
。如何使每个
消息
确认
工作,并重试有异常的
消息
?
浏览 11
提问于2018-02-19
得票数 0
1
回答
使用TIBCO EMS EXPLICIT_CLIENT_DUPS_OK_ACKNOWLEDGE的
Spring
JMS
确认
行为
、
、
我
在
Spring
boot应用程序中使用
spring
JMS
和
TIBCO EMS queue/topic。
在
我的代码中,我没有设置
确认
模式,所以我假设
spring
将
采用它的默认AUTO_ACKNOWLEDGE。我
在
侦听器onMessage方法中注意到的行为是,如果应用程序成功
处理
消息
,则不会重新传递相同的
消息
,而如果应用程序抛出RuntimeExcept
浏览 44
提问于2021-02-01
得票数 1
回答已采纳
1
回答
通过
JMS
与外部系统集成。集群环境
、
、
、
我有一个应用程序,其中我为外部系统A创建了2个
消息
侦听器容器,它分别侦听两个队列。 如果是,我怎样才
浏览 0
提问于2019-01-06
得票数 0
回答已采纳
1
回答
当显式打包
消息
时,ActiveMQ使用者需要打开吗?
、
、
、
我的应用程序通过从ActiveMQ读取
消息
来执行批
处理
。我通过实现MessageListener来阅读使用async
JMS
API。但只有
在
批
处理
通过调用message.acknowldge() 1成功时,我才会
确认
消息
。 理想情况下,我希望的是
在
进行批
处理
之前
,不会收到来自
JMS
代理的任何
消息
。但我怀疑
在
关闭消费者之后,我是否能够
确认
我<em
浏览 1
提问于2010-09-26
得票数 1
3
回答
将
消息
保留在队列中,以防接收器崩溃
、
、
我们有一个
Spring
JMS
消息
侦听器容器,用于异步接收
消息
。
在
sessionTransacted模式下使用DefaultMessageListenerContainer。我理解处于sessionTransacted模式意味着在出现异常的情况下,
消息
将被放回队列中。但是,如何确保
消息
不会从队列中删除,即使接收方(挑选
消息
的接收方)崩溃或只是运行该
消息
的机器断电?起初我认为
Spring
模式应该能救我一命,但并非如此,
浏览 2
提问于2010-04-13
得票数 3
1
回答
ServiceMix、Apache ActiveMQ、Camel为消费
消息
发送“完成”
、
、
、
我遇到的问题是:使用服务组合
和
camel路由,我通过activeMQ向消费者发送一条JSON
消息
。问题是这个消费者
处理
这条
消息
所花费的时间是X,所以消费者
在
消费
消息
的过程中可能会停止或崩溃。在这种情况下,
消息
将是一半消费者,并且已经从队列中删除,因为它已经被传递。 是否可以使队列
在
消息
被使用时不将其删除,而是
在
删除
消息
之前
等待消费者的
确认
,即该
消息</em
浏览 1
提问于2012-07-11
得票数 0
1
回答
如何在AUTO_ACKNOWLEDGE
JMS
会话场景中模拟
消息
重传?
、
、
、
、
在下面的测试中,我试图模拟以下场景:但是我的测试失败了,
消息
没有被重新传递给新的使用者。如果有任何提示,我将不胜感激。broker.stop(); }
浏览 5
提问于2012-03-26
得票数 7
回答已采纳
1
回答
JMS
事务-开销-如何避免它,如果可能的话?
、
、
、
在
我们的应用程序中,我们接收来自
JMS
主题的
消息
。我们正在使用缓存( hibernate )技术
和
事务来使用它。因此,我们使用两个事务,一个是
JMS
浏览 4
提问于2012-04-03
得票数 0
回答已采纳
1
回答
NiFi -
处理
后的
JMS
确认
、
、
是否可以
在
处理
消息
后使用NiFi
确认
来自
JMS
的
消息
?更具体地说,我希望使用
JMS
从队列中读取
消息
,
处理
它(使用多个NiFi
处理
器),使用PublishKafka
处理
器将其发送到Kafka,然后才向ConsumeJMS发送
确认
。换句话说,我不想在
消息
提交到Kafka
之前
从队列中删除它。 我知道有多种
确认
模式,但它们似乎都不能满足
浏览 33
提问于2020-08-11
得票数 2
回答已采纳
1
回答
在
spring
jms
容器中获取身份验证
、
、
我有一个从单独的应用程序接收
消息
的webapp。当webapp收到
消息
时,它会将
消息
发送给客户端用户。从本质上讲,我有一个监听传入
消息
的DefaultMessageListenerContainer。当MessageDelagate从单独的应用程序接收到
消息
时,messageDelegate实现使用SimpMessageSendingOperations通过队列将该
消息
发送给主体。constructor-arg ref="messageDelegate" /
浏览 1
提问于2014-11-20
得票数 0
1
回答
如果我的应用程序中断,如何用ActiveMQ恢复队列中的
消息
?
、
、
、
、
我有两个queues:parser-queue
和
generation-queue。我的应用程序运行在2不同的服务器中,两者都是监听的队列。我的工作流程非常简单,从解析器队列获取
消息
,
处理
它,并在工作完成后
将
另一条
消息
放入生成队列中。 但是,如果在我的工作过程中,得到
消息
并
处理
它,我的应用程序就会关闭,或者因为任何原因而中断。如何才能将未正确
处理
的同一条
消息
再次发送到我的队列以进行
处理
?我正在阅读关于的文章,但这似乎是
浏览 2
提问于2016-03-23
得票数 2
回答已采纳
3
回答
Spring
message listener /手动
确认
、
、
、
我知道这听起来像是听了1000次,但我不这么认为,我也找不到真正的解决方案:如何像ejb一样实现它?我的问题是:如果
消息
被
确认
,我根本不希望它被重新传递,即使发生了异常。
浏览 4
提问于2015-09-23
得票数 2
1
回答
使用CLIENT_ACKNOWLEDGE模式的Mule
jms
?
消息
被自动使用,即使我没有删除它
、
我对'CLIENT_ACKNOWLEDGE‘的理解是,我们必须在接收方或客户端显式地
确认
消息
,它不会消耗队列中的
消息
,直到它不
确认
为止。</
spring
:bean> </
spring
:bean> <
jms</e
浏览 1
提问于2014-08-27
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
ActiveMQ进阶学习
消息队列中间件(二)使用 ActiveMQ
分布式事务实践(二)-Spring的事务管理机制
Spring框架入门(一):概念简介
ActiveMQ消息队列的使用及应用
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券