我正在尝试寻找一些关于如何使用jms模板和spring从队列中读取消息的教程。本质上，我想让用户告诉我队列中最后x条消息的数量谢谢
浏览 0提问于2014-11-12得票数 0
我可以从azure函数中事件中心的所有分区获取消息，但我希望从azure函数中的特定事件中心分区获取消息。有办法吗？我想做的另一件事是，如果有大量的积压消息要处理，就增加(缩小)处理消息的azure函数的数量。我怎么能这么做？有什么公式可以解决我的第二个问题吗？
浏览 2提问于2016-12-06得票数 1
回答已采纳
这意味着我更希望上传器首先处理最近的读取，通过积累的任何积压时间向后移动。关于如何在RabbitMQ中实现最新消息</e
浏览 0提问于2015-05-07得票数 0
我是GCP的新手，在阅读有关通过数据流服务自动调优的文档时，他们谈到了积压和依赖于它的自动伸缩。在这种特殊情况下，什么是backlog？如果我的管道正在从发布/订阅中读取，它是最旧消息的年龄还是未确认消息的数量？
浏览 17提问于2021-05-28得票数 1
回答已采纳
订阅者接收消息并立即进入canceled状态。问题是，订阅者需要一些时间来处理每条消息，这意味着我通常有一些消息的积压-当订阅者获得canceled时不能再处理这些消息-- IMHO在ActorSubscriber.scala:195中。处理消息意味着我的订阅者将将工作卸载到其他人(通过soon的ChunkedMessage将内容发送回来)，并在消息完成后立即获得ack消息。当Actor被取消时，不
浏览 2提问于2015-08-29得票数 1
回答已采纳
2回答
我的应用程序作为ibm客户端来使用ibm服务器发送的消息。但有时他们会发送大量的消息(e.g:50000)。但是我们的客户端应用程序不能这么快地“吃掉”消息。编辑：
对于每条消息，处理时间类似于：(e.g:0:00:00.079)，但是等待开始处理下一条消息需要很长时间(e.g:0:00:00.534)
浏览 1提问于2016-02-08得票数 0
问题：一次只能处理10条具有相同服务的消息。一次只能处理4条具有相同服务和客户端的消息。必须按顺序保存具有相同服务、客户端和流的所有消息。例如，如果我执行一些基于内容的路由，将积压工作划
浏览 20提问于2013-01-07得票数 0
3回答
我们有一个AS400系统之间的集成，该系统以EBCDIC格式发送MQ消息，由TIBCO插件获取并处理。这些都是金融交易。但是，当我们从message浏览消息时，我们也会看到呈现为15125的数据元素值。
AS400团队指定，由于他们能够以25125的形式发送和接收，所以问题不在他们一方。以前有没有人遇到过类似的问题？这是MQ客户端的问题还是AS400 MQ传递消息的问题？
浏览 3提问于2015-09-15得票数 0
回答已采纳
如何向具有自定义超时的队列发送消息？(具体而言-1)我们通过向IAsynCollector发送类似于的示例来创建消息
我们最近处理了一个非常大的队列消息积压，每个消息都保存着用于处理的azure blob的名称。积压处理所用的时间比预期的要长，而且有些问题没有得到处理。我们认为它们超时是因为没有消息中毒，但是队列超时不是记录的事件。我认为这些消息会到达队列的后面，并超时。
浏览 1提问于2019-11-08得票数 0
回答已采纳
1回答
让我们假设两个银行系统(设为A和B)使用IBM通过发送消息来相互通信，假设A处有RecordA，B处有RecordB。当启动一个事务时，如果且仅更新了RecordB，则需要更新RecordA。MQ是如何做到这一点的？例如，从A处的AccountA中扣除100美元并将100美元添加到B处的AccountB的资金转账，
一种可能性是:A首先发起事务并向B发送消息，一旦MQ保证消息的交付，它就执行演绎，此时B也将执行加法如果MQ无法保证消息的传递，而实际上它可能已经传递了，该
浏览 7提问于2021-03-10得票数 0
2回答
我想从POSIX消息队列中删除所有消息。我在互联网上搜索，但我没有找到任何方法去做，相反，我找到了删除消息队列本身的方法，但这不是我的情况，我实际上想从消息队列中清除所有挂起的消息。我正在读取手册页，其中我找到了用于控制消息队列参数的mq_setattr API。我只是在想，如果使用mq_curmsgs将mq_setattr的值设置为0，它会清除队列中的挂起的消息吗？
浏览 6提问于2020-01-08得票数 2
回答已采纳
然而，现在需要处理的积压消息已经达到了大约15,000条。在调用AWS Lambda时，我一直得到"Firehose错误“，最大支持的函数超时是5分钟，因为我的lambda不能在5分钟内处理15k记录。
我怎么能让重试不同时发送这么多的记录呢？
浏览 2提问于2022-03-01得票数 0
1回答
它保留一个静态长度的消息积压，当有新消息可用时，它会返回消息列表中新的部分。或者这就是它看起来要做的事情。我知道我以前在编写一个简单的comet应用程序时实现过类似的东西。这是MQ可以做的事情吗？
浏览 1提问于2011-03-10得票数 1
回答已采纳
1回答
我有两个进程server.c和client.c，它们通过POSIX消息队列进行通信。客户端向队列发送一条消息，mq_notify告诉服务器一条消息已添加到队列中。然后，信号处理程序将接收并处理该消息。添加来自client.c的消息永远不会发送信号处理程序(但是，如果我添加来自server.c的消息，它将设置处理程序)。服务器仍然可以从客户端接收放入队列中的消息，但是由于某些原因，这
浏览 2提问于2013-02-28得票数 2
回答已采纳
我们尝试使用JMS模板发送MAP (java.util)，但在客户端我们无法读取消息，在服务器启动期间，spring boot @JMS侦听器抱怨以下消息，这适用于WAS 7，但不适用于WAS Liberty8.5.5，iam还包括代码片段以及我们为不同版本的服务器接收的不同消息格式。message); }WAS - LIBERTY消息格式以下是预期的消息
浏览 23提问于2019-07-11得票数 1
回答已采纳
2回答
我正在通过JMS从Mule连接MQ-8.x，最近我遇到了一个问题，似乎MQ写操作正在脱离同步点范围，由于这一点以及巨大的入站负载，MQ陷入了死锁状态。<spring:bean id="ConnectionFactory" class="com.ibm.mq.jms.MQConnectionFactory" name="ConnectionFactory
浏览 0提问于2018-08-28得票数 1
回答已采纳
在IBM中，当其提取计数器大于3时，是否有可能将消息从队列重定向到死信队列( WebSphere )？
浏览 18提问于2016-08-19得票数 1
回答已采纳
1回答
对于处理未能成功响应但成功提交数据库的消息，我有一些疑问。下面的顺序是处理的步骤。Cache.Timeout < MQ.Timeout3)数据处理包括读取存储。*所有数据应包括乐观锁定信息( 4) Cache.Get(MessageId
浏览 2提问于2017-03-05得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
