问题标签 [nms]

我正在尝试使用 MVC 作为发件人应用程序在 Apache ActiveMQ 中对消息进行排队，并且我在 c# 中构建了一个窗口服务作为 Apache ActiveMQ 的侦听器。但是我在上面的侦听器端阅读消息时遇到异常。

发件人 MVC 代码。

C# Windows 服务代码。

Window 服务端的异常当我展开消息对象'((Apache.NMS.ActiveMQ.Commands.ActiveMQObjectMessage)(message)).Body' 抛出类型为'System.Runtime.Serialization.SerializationException' 的异常

我正在尝试订阅类似于 ( org.omg.CORBA.MARSHAL: Server-side Exception: null )! 的通知服务和消费者警报，但出现编组错误。非常感谢有人可以帮助我解决我所缺少的或做错的事情。

idls 文件来自NotificationIRP idls并使用 jacorb-3.5 api。

NotificationConsumer.java

} }

结果

_NotificationIRPOperationsStub.attach_push 发生错误的地方（$in = _invoke ($out);）

While writing netty application I am not sure to which thread pool should i use for my pipeline handler.

either I should go with

or

Not sure about the difference between two.

Any help would be appreciated.

如何使用 ActiveMQ NMS (.NET) 获取队列和主题列表。在 JAVA 中获取列表很简单。但是.NET 呢？

在java中我使用了这个：

.NET 有类似的方法吗？

谢谢。

背景：
C# WPF 应用程序通过 ActiveMQ/JSON 与在 linux 上运行的 JAVA 服务器交谈
总共 5 个连接实例：
队列：2
主题：3（1 个生产者，2 个消费者）

问题：
在大量使用情况下（在不到 500 毫秒的时间内发送/接收大约 200 条消息的吞吐量，内存工作设置在 1-1.2 GB 左右），抛出“已建立的连接被主机中的软件中止”。

样本堆栈：

到目前为止尝试过：

• 关闭不活动监控以减少 5 个连接的流量。主要是因为应用程序有自己的心跳实现。
• 将 ConnectionFactory.OptimizeAcknowledge 设置为 true 以批量确认

背景：
C# WPF 应用程序通过 ActiveMQ(Apache.NMS)/JSON(Newtonsoft.Json) 与 linux 上运行的 JAVA 服务器通信

问题：
大于 85000 字节的 JSON 消息导致 LOH 碎片

可能的解决方案：
不是将 JSON 读取为 Apache.NMS.ITextMessage（目前就是这种情况），而是使用 JsonTextReader 获取底层流句柄并反序列化

实施问题：
Apache.NMS API 似乎不支持此功能，尽管 ActiveMQStreamMessage/ActiveMQBytesMessage 变体在这里并不真正符合要求。

我想知道有没有人有以上的经验？

我最近将一台服务器从 ActiveMQ 从 5.8 升级到了最新的 (5.11.1)。从那时起，我偶尔会注意到消息会在特定队列上堆积，而不会被删除。

我们的架构有一个生产者，一个消费者。我可以看到消费者仍处于连接状态，但来自生产者的消息正在堆积。我的解决方案是通过 Web 控制台删除队列。之后，我立即看到消费者重新连接并且消息再次开始处理。

如果相关，在这种情况下，生产者在 .NET 上运行 NMS，而消费者在 Java 1.7 上运行 JMS。

我是新开发人员，我在 java 文件中以 PDU 的形式获得了 SNMP 陷阱，我想将传入的陷阱转发到其他 IP 地址。

谁能帮我将 SNMP-Trap 转发到其他主机

Apache.NMS我有一个用于与 ActiveMQ 5.11 服务器通信的 .NET 应用程序。我通过 ActiveMQ 控制台注意到有 15k 条消息待处理。

奇怪的是，事实上，队列中有一个消费者，它正在从队列中拉出新消息（被另一个端点插入）。

从表面上看，这似乎是一个潜在的 ActiveMQ 错误。新消息怎么可能在服务器上“排在最前面”并被我的应用程序拉走，而 15k 待处理的消息却只是坐在那里？

作为测试，我重新启动了我的应用程序，作为初始启动的一部分，它将从队列中删除所有现有消息。这样做似乎可以让事情恢复到良好的状态，并且确实可以将所有 15k 消息从队列中拉出，然后继续正常运行。

我正在使用 Apache ActiveMQ 将我的应用程序集成到自定义服务中。我需要一直运行，而不是像现在这样运行一次。下面的代码有效，但仅适用于一条消息，我需要保持连接处于活动状态才能接收所有消息。

我做了一些研究，发现我应该创造一个耐用的消费者，这就是我尝试过的（评论线）。但它不起作用，它说网络连接无法订阅主题。

有任何想法吗？

PS：我对 ActiveMQ 完全陌生。

谢谢