问题标签 [nms]

我创建了一个测试，其中有两个消费者，每个消费者都使用自己的连接。我需要确保只有其中一个人收到消息。

这些消费者使用相同的 clientId 和名称。

每当我为第二个消费者设置 clientId 时，我都会收到以下异常：

Apache.NMS.InvalidClientIDException：代理：本地主机 - 客户端：TwoDurableConsumers_SameConsumerNameAndCientId_OnlyOneReceivesMessageb9182d05-b1b4-46b0-afb0-074b52ad7071 已从 Apache.NMS 的tcp://0:0:0:0:0:0:0:1:58629 连接。 c:\dev\NMS.ActiveMQ\src\main\csharp\Connection.cs: 1041 行中的 ActiveMQ.Connection.CheckConnected()

TwoDurableConsumers_SameConsumerNameAndCientId_OnlyOneReceivesMessageb9182d05-b1b4-46b0-afb0-074b52ad7071是clientId和durable subscriber name。

我正在用 C# 移植 Java 应用程序，我需要构建嵌入式 ActiveMQ 实例。

在 Java 中，我可以使用BrokerService类，但在 .Net 的Apache.Nms命名空间中找不到类似的东西。

了解如何使用特定端口参数启动 ActiveMQ jar 可能很有用。

任何人都可以帮助我吗？

我一直在使用 eclipse paho mqtt 库，那里有一个文件持久性选项。我在 apache nms 上找不到任何关于 mqtt 文件持久性的资源，因为我试图在 c# 中做同样的事情。有人用过这个吗？

我正在连接到托管在 AWS 上的 Apache Active MQ，以将我的应用程序集成到自定义服务中。我需要一直保持这种运行状态，而不是像现在这样一次。下面的代码有效，但仅适用于一条消息，我需要始终保持连接处于活动状态，以便接收所有消息。这是代码。

在控制台上显示以下未收到消息！几秒钟后控制台存在？

我们的客户端使用 2 个 ActiveMQ 节点连接到集群。当我们手动断开客户端和集群之间的网络连接时，Apache.NMS.ActiveMQ 库挂起。我们使用 Apache.NMS.ActiveMQ 版本 1.7.2 和基于 ActiveMQ 5.15.3 的集群。

连接 URI 为：

我希望该库在无法连接或重新连接时应该抛出异常，但它会永远挂起。

示踪剂日志：

我能做些什么来防止挂起？可能是 URI 中的其他连接参数？

我正在使用 ActiveMQ 来存储稍后使用的消息。它按预期工作，但是我需要适应一个我无法弄清楚的特定场景。简短的问题是这样的。

有没有办法在队列上运行查询以找出具有特定标头值的所有消息？

详细的问题是这样的：

因此，有一组数据包含在多条消息中，并且要求只有在所有消息都进来之后才使用该数据。因此，如果数据集有 50 条消息，我需要等待这 50 条消息，然后读入它们。我在每条消息中添加标题以表示它们属于某个集合。像 "TotalSets"=50 ， "SetId"=39 。如果特定批次的所有集合都已到达，我想编写一个线程来跟踪。

在对象检测算法中，非最大抑制（NMS）用于丢弃对象（例如车辆）的额外检测结果。

通常，水平边界框用于对象检测算法，水平 NMS 的 GPU 实现已经存在，但我希望 GPU 实现旋转边界框。

CPU 实现已经完成，但我正在努力使用 CuPy 包将 CPU 版本转换为 GPU 版本。这是我写的代码。在代码部分之后，您可以看到错误。

我的问题是 TypeError 的原因是什么：列表索引必须是整数或切片，而不是 cupy.core.core.ndarray？

错误是

CPU 实现占用：0.3672311305999756

回溯（最近一次通话最后）：

文件“nms_rotated.py”，第 117 行，在

文件“nms_rotated.py”，第 97 行，在 nms_gpu 中

TypeError：列表索引必须是整数或切片，而不是 cupy.core.core.ndarray

更新：13.02.2019 我试过@Yuki Hashimoto 的回答

通过替换iou = polygon_iou_gpu(polys[i], polys[order[j + 1]])为 iou = polygon_iou_gpu(polys[i.get()], polys[order[j + 1].get()]). 它不会抛出任何错误，但 GPU 版本比 CPU 版本慢几倍。

通过使用 100000 次随机检测：

我正在将我的 Java 应用程序迁移到 .NET Core。在Java中，我使用的是Spring Boot并且不太关心处理会话/消费者/等的打开和关闭（不知道我是否应该n_n'）。迁移到 .NET 我不得不在管理这些对象方面做更多的工作。

我的场景很简单：在启动我的应用程序时，我Connection使用远程代理启动 a ， a Session， aConsumer并注册 aMessageListener来处理消息。

问题是我的用户希望能够激活/停用侦听器并随时更改队列名称。知道我只是在缓存Connection对象，因此在收到“停用侦听器事件”或“更改队列名称事件”后，我可以简单地调用connection.Dispose()或connection.Close()重新开始所有创建过程。我的疑问是：

1. 是.Close()和.Dispose可互换的吗？还是我需要两个都打电话？
2. Connection仅关闭对象就足够了吗？我的会话和消费者也会死掉还是应该将它们缓存并完全关闭？
3. 如果以上就足够了，那么“微观管理”有什么优势吗？例如，当收到“停用侦听器事件”时，我可能只能Stop()连接而不是杀死它并不得不重新创建它。

以下是我开始我的听众的方式：

我在activemq中有问题。我想从我的 activemq 队列中收到一条特殊消息。我有超过 300 条消息，我想要其中一条消息。我用多选组合框解决了这个问题。在这个框中，我有我需要的所有属性的所有消息。

当我点击 247 项目时，我想选择接收消息的项目，在他们之后我想发送消息，但首先我遇到了接收问题。

我不知道为什么它不起作用。也许有人有想法？

我ProducerID的是正确的。但为什么这不起作用？它停在这条线上

我不知道了

我准备使用 C# 应用程序通过 ActiveMQ Artemis 发送和接收消息。在任播模式下，一切正常。

当我尝试在多播模式下发送和接收时，我可以发送，但我没有收到来自队列的任何消息。

我尝试了 java 的技巧，在 tcp uri 之前设置了“多播”标志，但显示一条错误消息，表明没有“多播”的实现

通常我会收到消息，因为我只从任播切换到多播，但实际上我什么也没收到。