问题标签 [nms]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
75 浏览

corda - 节点未从 Cordite 仪表板中删除

如何从cordite仪表板中删除节点?删除警报显示,但是当我单击删除按钮时,什么也没发生。我也尝试过招摇。目前m使用虚拟机。

0 投票
2 回答
8174 浏览

c++ - 如何在 C++ 中将 CSV 文件读入向量

我正在做将 python 代码转换为 C++ 的项目,以获得更好的性能。该python项目名称是Advanced EAST,现在,我在.csv文件中获得了nms函数的输入数据,如下所示:

一个单位是 7 个数字,但是在前四个数字之后有一个 '\n',我想把这个 csv 文件读入我的 C++ 项目,这样我就可以用 C++ 做数学工作,让它更快。

}

现在......我的代码 emmmmmm 无法正常工作,我完全不知道这个......请帮助我将 csv 数据读入我的代码中。谢谢

0 投票
1 回答
508 浏览

c# - ActiveMQ 队列计数停止在 400

我正在创建一个应用程序来连接到多个 ActiveMQ 服务器并获取具有不同队列的消息总数。

我正在使用此链接ActiveMQ with C# and Apache NMS - Count messages in queue 中找到的代码的略微修改版本,以计算队列中的消息。

我遇到的问题是,如果队列包含超过 400 条消息,则此代码停止计数为 400。

如何获取队列中的实际消息数?

为什么会出现这种行为?这是 IEnumerator 接口的问题还是 Apache.NMS.ActiveMQ API 的问题?

0 投票
0 回答
316 浏览

c# - 尝试使用 SSL 时出现 ActiveMQ 异常

我正在尝试使用适用于 .NET 的 Apache NMS API 通过 ActiveMQ 通过 SSL 发送安全消息。

在 broker.xml 中,我尝试将“sslEnabled=true”添加到默认接受器:

我正在尝试设置这样的消费者:

当代码到达 lineconnection.Start()时,我得到了这个异常:

频道太长时间处于非活动状态:tcp://localhost:61616/

我曾尝试像这样更改连接 url(中间是 ssl 而不是 tcp):

然后我得到了这个例外:

无法从传输连接读取数据:已建立的连接被主机中的软件中止

我在这里做错了什么?如何发送和接收安全消息?

0 投票
1 回答
67 浏览

c# - ActiveMQ NMS SSL:从远程机器运行应用程序

服务器 A 上部署了客户端 C# 应用程序。该应用程序与运行 ActiveMQ 并使用 SSL 协议的服务器 B 通信。在服务器 A 和服务器 B 上导入的证书(两个证书都进入当前用户存储:客户端证书进入个人文件夹,服务器证书进入证书颁发机构)。

直接从机器 A 运行应用程序当然没问题。但对于实际工作,用户必须使用服务器 A 上的共享文件夹从机器 C 运行 C# 应用程序。在这种情况下,无法建立连接。如果我在机器 C 上导入证书,它工作正常。

这是否意味着我必须在每台用户机器上导入证书?或者将服务器 A 上的证书放入本地计算机文件夹?

0 投票
1 回答
286 浏览

tensorflow - 调用 tf.image.non_max_suppression 时获取 ValueError

我想使用 tensorflow tf.image.non_max_suppression 函数。

我尝试了以下两个片段:

在哪里 和anchors_fit.shape[36864,4]rpn_cls_prob.shape[36864]

两个电话都加注:

我应该怎么办?

0 投票
1 回答
229 浏览

amqp - Apache.NMS.AMQP setting prefetch size

I am using Apache.NMS.AMQP (v1.8.0) to connect to AWS managed ActiveMQ (v5.15.9) broker but am having problems with setting prefetch size for connection/consumer/destination (couldn't set custom value on either of them).

While digging through source code I've found that default prefetch value (DEFAULT_CREDITS) is set to 200.

To test this behavior I've written test that enqueues 220 messages on a single queue, creates two consumers and then consumes messages. The result was, as expected, that first consumer dequeued 200 messages and second dequeued 20 messages.

After that I was looking for a way to set prefetch size on my consumer without any success since LinkCredit property of ConsumerInfo class is readonly.

Since my usecase requires me to set one prefetch size for connection that is what I've tried next according to this documentation page, but no success. This are URLs that I've tried:

After trying everything stated above I've tried setting prefetch for my queue destinations by appending
?consumer.prefetchSize=50 to queue name. Resulting in something like this:

queue://TestQueue?consumer.prefetchSize=50

All of above attempts resulted with effective prefetch size of 200 (determined through test described above).

Is there any way to set custom prefetch size per connection when connecting to broker using AMQP? Is there any other way to configure broker than through query parameters stated on this documentation page?

0 投票
1 回答
86 浏览

activemq - 如何在 C# 中设置 ActiveMQ 重新传递策略

我正在使用 C# 中的 ActiveMQ。我不明白如何在代码中设置重新交付政策。我试图在消费者端的代码中设置属性,但我无法理解它是否有效。

上面我已经设置了属性,但我不知道它是否正确。

0 投票
1 回答
75 浏览

c# - 在创建单元测试时,我能做些什么来防止该方法被调用?

我想强调一下,我对创建单元测试还很陌生,但我一直在通过谷歌和文档进行广泛搜索,但找不到解决方案或替代方案。所以目前我正在尝试为我的队友和我正在开发的微服务创建单元测试。类构造函数的结构如下

当我在单元测试中创建构造函数的新实例时,它将始终调用并遍历该AMQSubscriber();方法。天真的我只是做了一个重复的构造函数,它排除了该方法并添加了另一个参数:

但这仅用于单元测试目的。我已经阅读过这样做不是一个好主意,因为它违背了单元测试的目的,但我想不出如何隔离它,因为大多数方法都需要或依赖于参数:IOptions<AMQ_Config> amqConfig, IConfiguration configuration 而且我们的微服务是架构化的用于 Apache NMS AMQ 用于发送、处理和接收消息。

0 投票
0 回答
95 浏览

nms - 连接丢失或任何异常后的 ActiveMQ 恢复

所以我们有这个从队列中读取消息的逻辑:

我们的目标是在队列上有连续的监听器,当队列上有一些消息时会得到通知。我们正在使用故障转移连接,所以如果这足以涵盖网络闪烁和故障以使该侦听器不会停止,我会徘徊吗?如果出现一些错误,如何进行适当的恢复?我们是否需要再次注册监听器或者在这种情况下最佳实践是什么?这将用于多个不同的服务。