1回答
1、购买CKafka时的数量是指什么数量？
2、CKafka文档说兼容Kafka接口，是否所有可以访问原生Kafka的第三方工具都可以访问CKafka？
3、CKafka是否支持Kafka streaming接口？
浏览 225提问于2017-11-22
在腾讯云服务器上生产者给Ckafka服务器发送消息报错：org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.
浏览 5369提问于2018-10-10
1回答
我有一个春季消息监听器，它接收股票的价格( S1，S2，S3 .)。同一种股票的价格需要按顺序处理，因为不同股票的价格应该并行处理。
例如，如果价格顺序是S1-1，S1-2，S2-1，S1-3，S3-1，S2-2，S1-3，S3-2。然后应该有三个并行的处理流。
S1-1，S1-2，S1-3
S2-1，S2-1
S3-1，S3-2
目前，我正在并行处理所有内容，消息侦听器在消息到达时以soos的形式向priceInChannel发送消息。
<int:channel id="priceInChannel">
<int:dispatcher task-ex
浏览 3提问于2014-07-17得票数 0
假设每次价格变化时，我都需要向给定的股票代码发布价格，而在另一端，有订户(消费者)需要使用该价格。
这是一个典型的发布子模式(而不是点对点)。如果有N个使用者，并让发布者向每个N个队列发布相同的消息，那么设置N个队列是否是典型的做法？
我看不出只需要一个队列就能完成这一任务，因为每条消息只要一个消费者拿起就会消失(这是一个点对点模型)。
浏览 0提问于2018-03-14得票数 0
回答已采纳
2回答
我们的应用程序使用Azure服务总线进行消息传递。我们创建了很少的主题和订阅者。我们将每天发送大约500条消息，但在图表中，它显示了对500条消息的成千上万个请求。我们的账单价格也是每月800美元左右。这对500 * 30条信息来说太过分了。我无法理解为什么价格如此之高，我也想知道图中的请求意味着什么？
如果价格是因为要求的数目，那我又如何减少要求的数目呢？我看到了正确的信息。问题只在请求方面。
这只是一个样本图供你参考(不是原件)。在最初的图表中，我看到了大约100 k的500条消息请求。
浏览 4提问于2016-10-11得票数 10
回答已采纳
我们正在建立一个系统，为我们所有的客户预先计算所有价格。基于ERP中的某些触发器(例如价目表更改)，我们将把所有受影响的客户编号放入一个队列中，而一个侦听该队列的Azure函数将重新计算该特定客户的价格。
示例:对价目表进行更改后，用户单击保存。3000个客户受此更改影响，并被添加到计算队列中。如果计算需要2秒，并且我们可以并行进行10次计算，则3000*2/10=600秒后将完成最后一个客户的价格。当客户编号在队列中等待时，用户执行另一项更改并单击Save。在这种情况下，我们希望排除添加队列中已经存在的所有客户编号。
问: Azure Service Bus队列具有重复检测功能，但这是基于时
浏览 1提问于2020-04-23得票数 0
我在理解具有预定消息时间(“scheduledEnqueueTime”)的消息与生存期(默认为14天)之间的区别时遇到了一些困难。
他们之间有什么区别？我的理解是，在队列苏醒并执行去队列之前，我可以将其放置在队列中的最长时间是14天(默认)。这不对吗？
FYI -在我的应用程序中，我需要在队列中放置消息，在某些情况下，从今天起最多要60天才能醒来。我看到我可以把服务巴士的收费等级提高到标准价格，这样会增加生活的时间。这就是我要做的吗？
浏览 3提问于2021-05-03得票数 0
回答已采纳
3回答
最近，我遇到了一个带有50+服务的微服务体系结构，它使用发布/订阅进行消息传递。我以前使用过基于事件的系统，其中每个服务都创建和分发自己的事件，因此当我意识到这个(Theese)系统(S)实际上共享了许多消息类型时，我被告知了。
下面是一个虚构书店的简短例子。
消息发布者
所有者可以从OwnerService发布新的图书消息。
发布者可以从PublishersService发布新的图书消息。
作者可以从WritersService发布新的图书消息。
ShelfService可以发布BookPlacement消息。
BookPriceService可以发布BookPrice消息。
消息订阅者
O
浏览 0提问于2020-06-02得票数 1
回答已采纳
2回答
我有一个功能应用程序，监测swappa.com，并发送短信，如果有符合我的条件的手机列表。计时器触发器函数每15分钟检查一次swappa，队列触发器函数为每个匹配的列表发送一条文本消息。我只使用绑定来访问存储，使用twilio来保持额外的“功能”。
维护状态和避免发送关于相同列表的重复文本消息的最佳功能模式是什么？即使我能检查上市的年龄，价格可以降低较早的上市，使他们成为一个新的匹配。所以我需要跟踪已经处理过的个人清单。
浏览 2提问于2017-09-17得票数 0
回答已采纳
在同一个类中，我有一个CheckGuess方法，它从用户输入中提取一个整数并检查价格，如果不正确，它应该将其添加到previousGuesses中，然后当他得到正确答案时显示所有用户猜测。
在我的程序类中，在实际游戏结束后，用户猜测了价格，我需要显示他的尝试次数和所有猜测的统计数据：
\
问题是我刚刚学习C#，我不知道如何正确地将用户猜测的产品价格和描述添加到属性列表中
下面是我收到的错误消息：
任何可能的帮助
另外，什么时候打印保存列表中的属性值是正确的方式？
Console.WriteLine("Previous guesses:" + game.PreviousGues
浏览 38提问于2018-06-04得票数 -1
回答已采纳
我们有一个ActiveMQ队列，每秒将接收100k个股票订单消息(每个消息包含股票名称，售价，json格式的出价)。在100k消息/秒之外，可以有n个单一库存的no.of消息。如果我们收到多个相同库存的消息，那么我们需要使用java以相同的顺序处理所有这些消息。我们不能在一台服务器上使用单个监听器每秒处理10万条消息。需要使用多个侦听器和服务器来处理它，但在UI中使用与放在队列中相同的顺序显示结果。
读取股票队列-->验证请求-->更新界面中的股票价格
示例消息：-{ stockName:"TCS"，sellPrice:"102"，bidPrice:
浏览 0提问于2019-05-23得票数 0
2回答
我有一个容量为1的BlockingQueue，它存储收到的股票的最后价格。价格会一直留在队列中，直到客户端轮询队列为止。然后我有一个名为getLatestPrice()的方法，它应该返回股票的最新价格。我的问题是，如果客户还没有对最新价格进行轮询，那么最新价格可能不在队列中。它可能在阻塞的线程中。如果最新的价格被阻止，我最好的解决方案是什么？谢谢。
private final BlockingQueue<PriceUpdate> latest;
private final long pollTimeout = 2;
private TimeUnit pollTimeUnit = T
浏览 0提问于2014-01-19得票数 1
有个疑问，CKafka 使用了 Kafka 0.10，这个版本的消费组管理似乎是个问题，如何删除不再使用的消费组？你们打了补丁吗？
浏览 1278提问于2019-07-13
1回答
我们的Amazon队列没有接收来自Amazon的用于AnyOfferChanged通知的消息。
我们发送一个测试通知，这将发送到队列，并在收到通知时可用。
我们已经设置了两个AWS帐户，我们使用一个AWS帐户注册队列目的地并创建对AnyOfferChanged的订阅。另一个AWS帐户成功地从我们的队列中获得测试通知。
我们可以看到，商户的竞争对手已经更改了上市价格，但没有向我们发出任何通知。
有人遇到过这个问题吗？
浏览 7提问于2013-10-10得票数 2
2回答
我正在使用AWS EC2实例进行生物信息学工作。我有一个数量(~1000)的大文件，应该用EC2实例上的脚本来处理，结果应该上传回S3桶。我希望将作业(文件)分发给许多EC2实例，优先从现货价格开始。
我需要的是一个简单的排队系统(可能是AWS、SQS或其他什么)，它可以将作业分发给实例，并在实例失败时重新启动作业(因为现货价格过高或其他原因)。我已经研究过AWS示例，但它们太高级了，通常涉及自动缩放和复杂的消息生成应用程序。
有人能从概念上指出如何以最简单的方式最好地解决这个问题吗？这个AWS SQS的简单应用有什么例子吗？应该如何启动一组实例，然后如何判断如何侦听队列？
对于每个输入文件，
浏览 4提问于2015-03-04得票数 2
回答已采纳
我正在寻找一个Python插件，将计算实现的市盈率为许多股票交易使用先进先出的方法。
例如，假设我们有以下三个MSFT交易：
+75 MSFT 25.10
+50 MSFT 25.12
-100 MSFT 25.22
以25.22的价格卖出100股，将完全抵消以25.10的价格买入75股的影响，并部分抵消以25.12的价格买入50股的影响。
已实现损益= 75 * (25.22 - 25.10) + 25 * (25.22 - 25.12) = 11.50美元
未完成的职位将是：
+25 MSFT 25.12
浏览 2提问于2010-06-25得票数 6
从本质上讲，我有来自此代码的数据流，它每分钟都会更新最新的价格：
prices = data.history(context.stocks, "close", 15600, "1m")
我希望把这些历史数据放到某种列表中，每一分钟这个代码都会输入最新的价格和最旧的价格，在这种情况下，是第15600分钟被删除。
我该怎么做呢？以某种方式使用窗口？或者仅仅是将最新值添加到列表并删除最旧值的代码。
我很感谢你的帮助
谢谢，迈克
浏览 0提问于2016-05-04得票数 0
3回答
我正在使用Azure云服务和web api开发一个应用程序。我希望允许创建咨询会议的用户能够更改该会议的价格，但我想让所有用户离开会议30天之前，新的价格影响所有成员的当前注册的会议的价格。我的第一个想法是使用队列存储，并为30天的时间限制设置可见性超时，但这似乎会随着时间的推移快速增加队列，特别是如果消息不应该运行30天；更不用说排序问题了。我也在研究任务调度程序，但会话定价的变化不是一个反复出现的概念，而是更随机的。队列是一种很好的方法，还是有更好、更有效的方法来实现这一点？
浏览 1提问于2015-06-02得票数 6
我正在开发一个程序，它可以对来自互联网套接字的事件做出反应，也可能来自计时器。使用两个线程似乎很自然：
One用于主程序，第二个用于侦听套接字、解析输入并引发适当的事件。
所需追加经费：
应用程序不应该依赖UI线程(它可以作为控制台应用程序运行)。主程序应该同步处理消息，即消息到达的顺序。主线程不能阻止等待定时器(我猜这意味着我必须在不同的线程上运行定时器)。
以下是一些问题:-)：
--我猜需求#1 --意味着我没有内置的消息泵，所以我不能使用来自套接字侦听器/计时器线程的Invoke()。这是正确的吗？如何安全地在一个线程(例如侦听器)上引发事件，并让订阅者在另一个线程(主线程)上同步运行
浏览 2提问于2011-05-17得票数 4
回答已采纳
PriorityQueue<Player> playerQueue = new PriorityQueue<Player>(30,
new Comparator<Player>( ) {
// overriding the compare method
public int compare(Player i, Player j) {
return (int)i.playerPrice() < (
浏览 0提问于2012-07-09得票数 0
0回答
1、购买CKafka时的数量是指什么数量？
2、CKafka文档说兼容Kafka接口，是否所有可以访问原生Kafka的第三方工具都可以访问CKafka？
3、CKafka是否支持Kafka streaming接口？
浏览 192提问于2017-11-22
4回答
我正在设计一个java服务器，这将用于交易债券。此服务器将充当客户端UI和分析服务器之间的中介。分析服务器是大脑，我的服务器将简单地与其交互(使用tcp套接字)，并将响应转发给客户端。
服务器预计可并发处理约500个客户端。而且它必须是可伸缩的和高效的，可以每秒处理大约500条消息。
客户端UI和分析服务器之间的消息流如下所示：
1. Client through the UI requests for price.
2. My server accepts the message, formats it and then asynchronously
sends to the anal
浏览 4提问于2009-08-13得票数 0
回答已采纳
如果我们使用JMS来处理实时消息，例如实时的股票价格消息，如何在设计中使其具有最佳的性能和可靠性？例如，应该使用队列还是主题？如果消息到达，应该先保存到数据库中...，我们需要使用事务处理吗？
如果这段代码可以实现实时
public void onMessage(Message msg) {
final long currentTime = System.currentTimeMillis();
Thread timer = new Thread(new Runnable(){
@Override
public
浏览 2提问于2011-12-14得票数 0
我想使用System.Collections.Generic.Queue，但有一个不同之处:我希望Queue.Peek返回最后一项，而不是第一项。我仍然希望项目以同样的方式进入和退出。
我正在考虑使用Queue.Last()作为Queue.Peek()的替代方案(我假设它与Queue.First()基本相同)，但我想知道这是否意味着枚举器在到达最后一个元素之前会对整个队列进行字面上的枚举。由于我的队列将非常大，这可能是一个问题。
编辑：
把我想要做的事情说清楚:比如说，我想一分钟一分钟地保存过去20年中股票价格的数据库。这将是许多数据点。为了做到这一点，我希望在每一分钟都要排起最新的价格，当排
浏览 3提问于2015-05-05得票数 0
回答已采纳
假设我的网上商店和数据库有多个表，比如Products、Product prices和类似的表。我要把我的软件解决方案卖给我的合作伙伴。他得到了它的数据库，它输入数据的窗口应用程序，我希望他的所有产品也在我的网站上。所以，我有我的产品，并在我的网站上销售它们。合作伙伴有他的网站和他的产品，但我也希望他的所有产品也在我的数据库中。我最初的想法是构建一种应用程序，定期连接到合作伙伴的数据库，并在我的表中插入/更新数据。但最近我想到了一些服务总线。服务总线是可行的吗？所以情况会是这样的。合作伙伴插入产品(总线发送产品已插入的消息，合作伙伴更新价格，然后总线发送价格行中某一行已更改的消息。然后我会有一
浏览 0提问于2017-06-01得票数 0
1回答
同步发送请求
、、、
嘿，我在做什么，我必须向雅虎发送请求，要求提高股票价格。我需要发送的公司名称在数组n中，我也编码为只发送100个公司的请求，但发生的是请求一次发送所有请求，因为它不等待响应，所以我只收到前100个公司的响应。如何同步发送请求？？也有像锁一样的求和可以用来做这件事。
浏览 2提问于2010-08-07得票数 0
回答已采纳
4回答
我目前正在使用SendGrid从许多无服务器的node.js Lambda函数发送电子邮件，并计划从SendGrid传输到SES (因为价格合理)。
SendGrid的速率限制是如此之高，以至于通过某些lambda函数同时向用户发送电子邮件，不会造成问题。但是SES有较低的速率限制(在我的例子中是每秒50封电子邮件)，最大发送速率限制超过错误发生。
如何在不超过利率限制的情况下尽快发送电子邮件？
我目前的计划是通过多个lambda函数向SQS队列发送电子邮件请求，并接收SQS消息，通过一个Lambda函数不间断地运行来发送电子邮件。但我不知道如何控制向SES发送请求的速度。
浏览 12提问于2020-05-10得票数 3
回答已采纳
1回答
在我的公司，我们使用Event Sourcing模式来实现对预订价格的所有更改的存储。在整个公司中，不同的服务可能会尝试将事件附加到由预订代码标识的预订中。 我们使用DynamoDB来存储事件，并且它确实支持一致读取。事情是这样的，当最初进行预订，并且为预订代码创建了第一个事件时，如果我们由于任何原因未能保存到DynamoDB中，我们将该事件放入回退队列，并简单地向客户端返回成功，以确认我们已经收到了该事件。然后，客户端可以继续其业务逻辑流程，并反过来向最终用户显示成功消息。我们的目标是不会不惜一切代价阻止预订创建。 问题是，在很短的一段时间内，当事件仍在回退队列中时，如果客户端尝试使用预订
浏览 15提问于2021-10-07得票数 0
我有一个websocket客户端，每秒从websocket流接收200-300条消息。接收消息的JavaScript客户机正在对接收到的每条消息执行一些DOM操作。我担心在浏览器中运行应用程序几分钟后，消息的处理可能会落后。就像聊天应用程序被收到的消息淹没，一段时间后，接收websocket消息和向用户显示消息之间的延迟会越来越长……另一个例子是实时股票市场页面，但在打开几分钟后，实时价格就不再是实时的了……
如何确定浏览器是否与传入的websocket消息保持同步？
更新
我最终让页面上的每条消息都更新了一个时钟，看看它是否落后了：
function onMessage(evt)
{
v
浏览 0提问于2018-02-03得票数 0
1回答
商务进出口价格提供的特殊价格属性是不可翻译的。尤其是RRP。我不能更改这些字段的翻译。我可以写标签在显示对话框，但它是不可更改的，取决于网站的语言。我该如何解决这个问题？
浏览 0提问于2016-01-20得票数 1
回答已采纳
在我们的教科书中，有一章是关于藏书的，但对于它的意义却很少有解释。有些例子是有帮助的，但我还是有点不明白这些陈述的意义。这是一本书中使用的：Map<String, ArrayList<Integer>>。我知道我们用的是地图。我相信第一个输入是一个字符串值。在这个例子中是一个学生的名字。第二是学生成绩。为什么要创建一个ArrayList？
我必须编写一个程序，我们已经得到了一些代码。我复制了下面的程序，这样你就有了上下文。但是，如果有人能解释Map<String, Queue<Block>>的含义，那将是非常有帮助的。它是怎么用的。非常感谢!
假
浏览 7提问于2022-12-01得票数 -1
我在NodeJS中有一个客户机，它使用MQTT模块(mqtt.js)与WebSphere MQ的主题通信，然后重定向到队列:我需要结果在队列上，所以我在源和目的地之间使用了一个主题(因为MQTT协议只与主题通信)。
所以我们有：NodeJS (源) ->主题Websphere MQ (中间) Websphere MQ (目的)的->队列
问题是，WebsphereMQ队列上接收到的消息是MQHRF2格式的，但我需要MQSTR。
我没有在mqtt.js端找到任何属性来指定格式。
我想我们可以通过强制使用它，但是如何实现呢？我可以为这个使用创建一个通道或任何东西，也就是说，转换接收格式
浏览 2提问于2016-07-12得票数 2
回答已采纳
1回答
我需要运行一个报告，它需要从作为Azure运行的WCF服务中提取信息。不幸的是，我需要运行大约6000个请求，它们必须单独运行。
当我把整本书都扔在仪式上时，我得到了
ASP.NET rejected this request because the queue limit was exceeded.
我找不到任何信息，说明每个价格层的请求队列限制是什么。
有谁知道限制是什么吗？
浏览 2提问于2015-11-04得票数 1
回答已采纳
1) LoadRunner是否有MQ协议？
2)是否可以使用LoadRunner Vuser将加载(放入消息)驱动到MQ队列？
3)我们是否需要从惠普或其他供应商那里购买一些东西来做到这一点？如果是的话，来自哪个供应商，估计价格是多少？
请解释一下。
浏览 2提问于2011-08-26得票数 0
1回答
我在while(True)循环中发出get请求，以便不断接收金融资产的最后价格，同时需要程序的rest代码独立完成。 如何使用线程来实现呢？问题是我不知道如何将无限循环与线程返回值集成在一起
浏览 25提问于2021-10-17得票数 0
假设我想要一个装有不同价格的苹果的容器。我希望它们总是按照它们的价格排序(最高价优先)，但我也想通过它们的id快速检索它们。到目前为止，我所掌握的内容如下
struct AppleClass
{
string id;
int price;
bool operator<(const AppleClass& o) const
{
return price > o.price;
}
};
int main()
{
set<AppleClass> myapples;
myapples.in
浏览 1提问于2016-05-09得票数 5
目标
我最终想要实现的是基于数量的分层定价。
客户根据数量销售不同的价格。我试图找出使用字段存储、访问和表示这些数据的最简单方法。同时，我通过商业饲料导入它们。
关于我的提要/数据的
我有一个CSV表头，其中列有"P1价格“、"P2价格”和"P3价格“。还有"P1 Qty“、"P2 Qty”和"P3 Qty“。
因此，P1价格与P1数量等相对应。
我的问题
就不那么复杂的规则或视图配置而言，从长远来看，如果我创建了单独的字段来存储每个价格/数量，或者将它们组合成一个存储6个不同值的字段，它会更简单吗？
我的主要考虑因素包括可伸缩性、可维护性等
浏览 0提问于2011-08-26得票数 4
回答已采纳
我计划在我的电子商务产品页面上显示所有产品的新价格.这是每月分期付款的价格。我需要显示这低于正常价格(可变价格和简单价格)这样的东西。
0%利息分期付款，从3,093卢比开始
其中3093卢比是新的价格。
这是我在W3学校尝试过的计算，我的计算是正确的。
而60000是产品的价格乘以这个数字5.15464除以100。
答案是3,093 (答案应舍入到最接近的整数)
为此，我需要一个自定义函数，可以在其中添加到我的functions.php中。
<script>var x = myFunction(60000, 5.15464, 100); function myFunction(a
浏览 0提问于2019-08-10得票数 1
我不明白Bloomberg API的问题出在哪里。
每次当我尝试下载历史金融数据时，这意味着为5000种工具创建一个为期3天的DataRequest，一次用于欧元货币，一次用于当地货币，我得到这个队列异常。
真正令人困惑的是，程序仍然会继续执行第一个请求，其中包含工具的欧元价格，而不是第二个请求。
谢谢你的帮助。
浏览 1提问于2012-05-29得票数 2
2回答
我将价格发送给客户(10000+)，但下面的代码有循环，导致客户等待计算过程中的延迟。
PriceVisibleForCustomer =价格+ CustomerMargin
价格-每300毫秒更改一次-从中心商店发送，与客户实例无关
CustomerMargn -由客户协议/部门/管理员决定等产生的一些正负金额。它在客户http会话期间不会更改，我可以将其保存在内存中
客户-他在登录后的过程中，他应该看到8种产品的快速变化的价格。
也许我需要更多的技术？我有Spring3/4，Java，Weblogic，我甚至可以为这个任务创建单独的webapp来提供计算价格。
我想过在Java语言中使用线
浏览 10提问于2015-07-18得票数 6
对分配的解释:只使用集合框架，编写一个允许用户买卖股票的程序。我不允许使用用户定义的类。
股票需要有一个3个字符串来表示股票的名称，一个整数数量的所述股票，并且每一种股票的价格都是以。
如果用户从同一家公司购买了两个实例的股票，则首先购买的股票首先出售。先到先出。
我尝试创建一个带有字符串键的映射和一个以嵌套的ArrayList作为值的队列。我想将股票价格和股票数量的ArrayList推到队列中。我认为，使用FIFO的队列将非常适合跟踪和处理以同一股票名称购买的大量商品。字符串键将是股票名称，它的所有购买将按顺序记录在它下面。
不幸的是，我似乎找不到真正到达队列的方法，除非( a)覆盖已经包含
浏览 3提问于2019-10-15得票数 0
我有多个进程来提交产品，价格和数量数据的饲料。
它节流，我无法跟踪提要提交的请求数量。
有没有一种简单的方法可以知道提要当前是否正在节流。
如果没有，并且我提交了限制订阅，亚马逊可以阻止我太多的请求吗？
浏览 12提问于2019-07-06得票数 1
回答已采纳
2回答
已接受的重新排队消息
、、、、
我有一条消息在队列中，但是当消息被成功触发时，我不想从队列中删除该消息。我想将消息保留在那里，以便在另一个时间重新触发，有人知道如何为此配置rabbitMQ吗？
浏览 1提问于2016-08-30得票数 0
3回答
在CMS上进行并发仲裁
、、、
我正在建立一个自定义的CMS，允许用户发布消息到它。消息很短，就像推文一样。
问题是这些消息是由真正的版主主持的。并且有多个版主同时处理消息流。我担心的是，如果这些版主都在处理同一条消息，那该怎么办呢？这既是低效的，也是不一致的。因为一条消息可以被一个版主拒绝，然后由另一个版主传递。
因此，我希望建立某种机制，以便CMS可以将这些消息分发给不同的版主，并避免重复。CMS期望在短时间内处理大量的消息。因此，这个问题变得更加严重。
任何想法都是值得欣赏的。干杯。
浏览 2提问于2010-08-21得票数 0
1回答
假设我有两个独立的服务，A和B，其中的SQS队列都订阅了SNS主题“topic”。然后，我向SNS主题“主题-foo”发布一条消息m1。
如果服务A( SQS )拥有的SQS队列看到并处理消息m1 (即从队列中弹出消息并处理消息，使其不再在sqs上)，是否仍然可以保证服务B(Sqs)拥有的单独的sqs队列始终能够看到和处理消息m1？(换句话说，AWS发布是否保证将多个消息传递到SQS队列并隔离单独的SQS队列处理？)
浏览 1提问于2017-12-20得票数 0
回答已采纳
我正在使用由IronMQ提供的IronIO服务的警报功能来启动工作人员。
我设置了一些东西，以便将消息推送到推送队列中。推送队列发送启动工作人员的警报。工作人员在推送队列中删除消息，并保留它。有时，由于作业失败的原因，对消息的保留过期，消息再次可用。然而，据我所知，当预订在消息上过期时，不会发送任何警报。因此，该消息位于队列中，直到另一条消息被添加到队列中，触发警报并启动工作人员。但是新消息没有被处理。
是否在IronMQ中为有保留的邮件创建了警报？有没有什么我错过的描述会发生什么的文件？
我的工作是让员工获取多条消息，但在处理同一员工中的多条消息时，我遇到了与铁io无关的问题。
还有一种方法
浏览 5提问于2014-08-15得票数 1
回答已采纳
我在一个生产系统上有一个Tibco EMS消息队列，它将消息从一个生产者路由到一个消费者应用程序。
我们正在垂直扩展应用程序，但由于财务限制，我们无法成对扩展这两个应用程序。
单个生产者将消息路由到消息代理，并且消息代理将需要基于消息选择器将消息桥接到3个消费者中的1个。
我已经设置了一个队列桥和选择器来将生产者队列上的消息路由到消费者队列。这是一个1对多的队列桥。
我注意到桥接的消费者队列具有连接到它们的消费者，并且它们基于选择器正确地接收消息，但是生产者队列保留了必须在一天结束时手动清除的消息的副本。
使用桥接器和选择器处理此场景的最佳方式是什么，以便消息保留在代理上，直到它被使用(持久)
浏览 39提问于2016-09-27得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
