问题标签 [apache-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 回答
325 浏览

.net-core - 使用 Apache.NMS 从 C# (.net Core) 读取 ActiveMQ 虚拟主题的“旧”消息

如何使用 Apache.NMS 阅读有关虚拟主题的消息?

在创建连接、会话和消费者之后,我执行:“consumer.Receive();”。

在代码运行时发送的消息会被接收,但在此之前已经在主题上的任何消息都不会被接收。

我尝试在主题中添加“?consumer.retroactive=true”,但这似乎没有任何作用。

我见过使用持久订阅者的示例,但是当使用虚拟主题时,我不应该这样做。

0 投票
1 回答
22 浏览

c# - 如何在 activeMq 中设置 MessageSelector

我有一个运行并轮询 ActiveMQ 中的消息的进程。现在我在设置消息选择器时遇到问题。队列已连接并从队列中提取消息,没有选择器。

如果我添加一个选择器,它只会中断一个只包含选择器字符串的异常。

尽管我阅读了很薄的文档,但我并没有真正理解问题,我使用了屏蔽字符串并使用了格式,但没有运气。

队列中的消息具有以下属性/值对作为其属性之一,因为我可以在队列中的 web 面板中看到该消息:

F_IMGKOMP.PIMG_SOURCE_FILENAME = EURDE_500.jpeg

精简后的代码如下所示:

0 投票
2 回答
461 浏览

activemq - 有没有办法以编程方式删除 ActiveMQ 作业计划?

我正在尝试删除 ActiveMQ 中的计划作业,但到目前为止还没有运气。

使用NMS APIAmqpnetlite在消息中创建计划(openwire lib 除外,因为该库未更新且不能在 netstandard/netcore 上使用)

用于使用 NMS 创建计划的示例代码,与 AMQP 库相同:

这部分在浏览器控制台中产生以下结果,这就是我愿意删除的:

代码结果

我已经阅读了这个其他问题和答案,还有活动的 mq 系统常量,但没有办法删除计划。还尝试浏览文档,但到目前为止找不到任何有用的东西

ActiveMQ 是否甚至支持以编程方式管理计划?AMQP 解决方案会很棒,但 NMS 也值得赞赏。

0 投票
1 回答
599 浏览

c# - System.RAP 报告 azure service fabric 项目的属性 IStatelessServiceInstance.OpenDuration 错误警告

我正在开发一个 Azure Service Fabric 项目,该项目使用 Apache.NMS .NET 库从 ActiveMQ 读取消息,并创建持久的消费者以从 ActiveMQ 中读取特定消息。

我能够阅读该消息并且一切正常,但我收到如下警告。

此警告会导致服务出错,因此我需要删除该警告。

任何人为什么它给我警告。

这是我如何阅读消息的快照。

0 投票
1 回答
739 浏览

c# - How to connect to ActiveMQ over SSL from Apache.NMS C# client library

I have a server where we have installed ActiveMQ and also generate the necessary certificates for SSL.

I have added a broker certificate to my local machine's Keystore and then tried to connect ActiveMQ over SSL but getting an error like: not able to connect using ipaddress:61617.

Everything is working fine with TCP but the problem is when I tried to connect over SSL.

Here is the code snippet for connecting to ActiveMQ.

I am referring to this documentation for setting up SSL.

Here is the Active MQ endpoint that I am trying to connect. activemq:ssl://server-ip-address:61617

I am using Apache.NMS.ActiveMQ version 1.7.2

I have added the following line in trasportconnectors section in activemq.xml file.

0 投票
1 回答
235 浏览

activemq - ActiveMQ 故障转移传输选项未按预期工作

我想使用https://activemq.apache.org/failover-transport-reference.html中描述的 ActiveMQ 故障转移传输。

默认的“永远重试”故障转移选项按预期工作。

但是,由于“永远”有时太长,我尝试设置一些选项以便提前终止重试。

例如,在启动时,如果在第一次尝试时无法建立与代理的连接,我想立即终止应用程序。

我尝试了最简单的选择:

但令我惊讶的是,重试仍然“永远”进行。

我尝试了许多其他选项组合,例如

但没有想要的结果。

我究竟做错了什么?如果代理不可用,如何配置故障转移传输以便在启动时终止重新连接尝试?

我正在使用 ActiveMQ 版本 5.15.9 ( https://hub.docker.com/r/rmohr/activemq ) 和 Apache.NMS.ActiveMQ 库版本 1.8。

相关的代码片段是

0 投票
0 回答
119 浏览

c# - Apache.NMS.AMQP.ConnectionFactory 得到错误 TypeInitializationException

我正在尝试使用 Apache.NMS.AMQP 向 ActiveMQ 发送消息。但有错误

说到这一行:

当我在 Visual Studio 中手动调试它时,它工作正常,并且没有出现错误。但是当涉及到 Biztalk 时,它会出错System.TypeInitializationException

Apache.NMS.AMQP 没有强名称签名,所以我使用 Ildasm 和 ilasm 对其进行了签名。然后放到全局gac中。任何帮助表示赞赏,我正在使用 .NET 框架 4.6.1。

0 投票
1 回答
55 浏览

linux - 在 Linux 环境下,ActiveMQ 消息从队列中消耗更多

我正在本地和 IIS 中创建一个示例 .net 核心解决方案,在一秒钟内消耗队列中的较大消息,但我部署在 Linux 服务器中可能需要更多时间来消耗队列中的消息。我不知道如何解决它请帮助我。下面我附上了我的示例代码。