nms相关内容

如何设置NMS侦听器容器的预取限制

除了在连接URL上,我如何在spring config中设置预取限制.我找不到任何属性的文档,并且Connection URL上的参数似乎不起作用.此外,我需要在消费者层面上做到这一点.这是我下面的配置. ..
发布时间:2020-08-19 23:26:24 其他开发

ActiveMQ:批量发布,持久发布消息,但不是异步发布消息?

是否可以批量存储大量消息? 我想让它们同步,持久地发送,但是一次要非常快. 我正在使用NMS(Java框架的.net版本).但是,如果您只知道如何在Java中执行此操作,那么它甚至会有所帮助.也许我可以更轻松地找到.net的解决方案. 我想到了诸如交易之类的事情.但是我只让交易对消费者有用,而对生产者没有作用. 解决方案 传统的建议是,如果您希望在批量发送时获得最大的吞吐量,那 ..
发布时间:2020-08-19 23:26:22 C#/.NET

我可以使用C#代码从ActiveMQ队列中删除消息吗?

我想为消息头中的每条消息设置唯一的GUID,然后根据需要删除特定的消息。 NMS中是否有任何api可以帮助我删除邮件?我正在使用ActiveMQ 5.9.0和NMS 1.6.1 解决方案 非常有可能直接从C#和NMS库中进行单个删除 我在C#项目中使用NuGet的NMS 18.0作为我们的支持和维护工具 Nodinite ,这是来自许多 ..
发布时间:2020-06-01 19:22:42 其他开发

连接断开时,Apache.NMS.ActiveMQ客户端挂起

我们的客户端连接到具有2个ActiveMQ节点的群集。当我们手动断开客户端和群集之间的网络连接时,Apache.NMS.ActiveMQ库将挂起。 我们使用Apache.NMS.ActiveMQ版本1.7.2和基于ActiveMQ 5.15.3的集群。 连接URI为: 故障转移:(tcp:// dd-amq-app01:61616,tcp:// dd-amq-app02:61616) ..
发布时间:2020-06-01 19:22:19 C#/.NET

在连接到AWS上设置的ActiveMQ时,连接会在几秒钟后关闭

我正在连接到托管在AWS上的Apache Active MQ,以将我的应用程序集成到自定义服务。我需要始终保持运行状态,而不是像现在这样。下面的代码有效,但是仅对于一条消息,我需要一直保持连接处于活动状态,以便接收所有消息。 这是代码。 使用Apache.NMS; 使用Apache.NMS.Util; 使用系统; 使用System.Collections.Generic; 使用Sy ..
发布时间:2020-06-01 19:22:12 C#/.NET

ActiveMQ NMS:当代理关闭时,connection.start()与故障转移协议一起挂起

我有使用nms.activemq 1.5.0的C#应用​​程序。 当我的应用程序启动时,它尝试使用故障转移协议连接到代理(我有两个代理)主从配置)。 如果由于 connection.start()而使我的应用程序停滞不前,则 我尝试了在网络上找到的所有信息-我尝试了故障转移协议的每个属性,还尝试了设置连接超时,尝试了 transport.requesttimeout 。 我 ..
发布时间:2020-06-01 19:11:50 其他开发

如何访问.net中的activemq统计信息插件

我正在尝试访问activemq统计信息 http://activemq.apache.org/statisticsplugin.html 在c#中 这是我到目前为止所拥有的。我无法从消费者那里得到答复。我可以在监视器网站上为队列增加计数。 公共类统计 { private只读字符串queueName = string.Empty; 私有只读字符串queueToMonitor = s ..
发布时间:2020-06-01 19:10:34 其他开发

如何监视Apache Artemis

我正在Windows .NET环境中对RabbitMQ,ActiveMQ和Apache Artemis进行一些测试。 RabbitMQ和ActiveMQ带有Web界面,您可以在其中查看有关代理,队列,消息等的信息,而Artemis则没有。我真的很希望能够在Web界面中或至少使用一些cmd / PowerShell命令监视Artemis经纪人。 我在此页面有关一些可用于监视ActiveMQ的第 ..
发布时间:2020-06-01 19:09:43 其他开发

ActiveMQ的 - 发送消息到一个临时队列使用字符串指定的NMS(在C#)

我有我的系统中的同步消息交易,这个过程大致遵循以下流程: “点A”创建一个临时队列(“目标2”)的消息代理; 信息从A点传送到目的地1(在消息代理标准队列),设定为目的地2的ReplyTo地址; A点块等待响应目的地2; b点距离目的地1接收消息; b点创建工作对象 - 它的属性是目标2(使用的ToString()“这项工作对象序列衍生并存储在数据库的名称; 。 ... ..
发布时间:2016-10-08 14:10:07 C#/.NET

什么序列化方法被用于一个ActiveMQ的网管系统C#对象消息?

我打算使用Apache网管进行ActiveMQ的消息,并想知道什么序列化方法将是对我送的对象使用呢? XML /二进制?什么控制序列化,我怎么可以自定义的呢? 没有人有经验与C#对象这样做呢?是否有你知道的任何陷阱? 解决方案 默认为System.Runtime.Serialization.Formatters.Binary.BinaryFormatter为IObjectMessage。 ..
发布时间:2015-11-26 19:36:08 C#/.NET