问题标签 [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.
.net-core - 使用 Apache.NMS 从 C# (.net Core) 读取 ActiveMQ 虚拟主题的“旧”消息
如何使用 Apache.NMS 阅读有关虚拟主题的消息?
在创建连接、会话和消费者之后,我执行:“consumer.Receive();”。
在代码运行时发送的消息会被接收,但在此之前已经在主题上的任何消息都不会被接收。
我尝试在主题中添加“?consumer.retroactive=true”,但这似乎没有任何作用。
我见过使用持久订阅者的示例,但是当使用虚拟主题时,我不应该这样做。
c# - 如何在 activeMq 中设置 MessageSelector
我有一个运行并轮询 ActiveMQ 中的消息的进程。现在我在设置消息选择器时遇到问题。队列已连接并从队列中提取消息,没有选择器。
如果我添加一个选择器,它只会中断一个只包含选择器字符串的异常。
尽管我阅读了很薄的文档,但我并没有真正理解问题,我使用了屏蔽字符串并使用了格式,但没有运气。
队列中的消息具有以下属性/值对作为其属性之一,因为我可以在队列中的 web 面板中看到该消息:
F_IMGKOMP.PIMG_SOURCE_FILENAME = EURDE_500.jpeg
精简后的代码如下所示:
activemq - 有没有办法以编程方式删除 ActiveMQ 作业计划?
我正在尝试删除 ActiveMQ 中的计划作业,但到目前为止还没有运气。
使用NMS API或Amqpnetlite在消息中创建计划(openwire lib 除外,因为该库未更新且不能在 netstandard/netcore 上使用)
用于使用 NMS 创建计划的示例代码,与 AMQP 库相同:
这部分在浏览器控制台中产生以下结果,这就是我愿意删除的:
我已经阅读了这个其他问题和答案,还有活动的 mq 系统常量,但没有办法删除计划。还尝试浏览文档,但到目前为止找不到任何有用的东西
ActiveMQ 是否甚至支持以编程方式管理计划?AMQP 解决方案会很棒,但 NMS 也值得赞赏。
c# - System.RAP 报告 azure service fabric 项目的属性 IStatelessServiceInstance.OpenDuration 错误警告
我正在开发一个 Azure Service Fabric 项目,该项目使用 Apache.NMS .NET 库从 ActiveMQ 读取消息,并创建持久的消费者以从 ActiveMQ 中读取特定消息。
我能够阅读该消息并且一切正常,但我收到如下警告。
此警告会导致服务出错,因此我需要删除该警告。
任何人为什么它给我警告。
这是我如何阅读消息的快照。
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.
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。
相关的代码片段是
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。
linux - 在 Linux 环境下,ActiveMQ 消息从队列中消耗更多
我正在本地和 IIS 中创建一个示例 .net 核心解决方案,在一秒钟内消耗队列中的较大消息,但我部署在 Linux 服务器中可能需要更多时间来消耗队列中的消息。我不知道如何解决它请帮助我。下面我附上了我的示例代码。