apache-nms

0热度

1回答

我正在使用STOMP协议读/写消息到/从Rabbit MQ（3.6.5）队列。我使用Apache NMS Stomp（1.5.4）作为客户端库。使用NMS发送消息时，出现下列异常：输入字符串格式不正确。的原因是，NMS预计日提交邮件ID含有在特定位置的数字。这是从NMS库中的代码： public void SetValue(String messageKey) { key =

0热度

2回答

如何以long（datatype）的形式发送消息给activemq负载？

我正在使用.NET 3.5将消息发送到活动mq，并且我有一个从队列中处理这些消息的java侦听器。部首包含 userId - long type - string isAdd-bool 监听期待有效载荷是数据类型的长。所以我应该在有效载荷中发送数据类型。这里是我用来发送消息到活动mq的代码。 string payLoad = "123"; IConnectionFactory fa

2热度

1回答

.NET中的ActiveMQ连接启动超时

我有用于ActiveMQ的.Net客户端。我使用Apache.NMS 1.5.1.2739和Apache.NMS.ActiveMQ 1.5.6.2746 我使用的后续代码连接到代理： var connectionFactory = new ConnectionFactory("failover:tcp://127.0.0.1:61616/?transport.timeout=5000"); I

0热度

1回答

如何从沙箱中调用Apache NMS？

我想从我的代码（'IntPub'）中调用Apache ActiveMQ NMS版本1.6.0，该代码必须在.NET 4.0环境的沙箱中运行，出于安全原因。创建沙盒的程序使我的代码“部分可信”，因此“安全透明”，这似乎意味着它不能创建ConnectionFactory（请参阅下面的错误日志），因为NMS似乎是'安全关键'。下面是导致此错误代码： connecturi = new Uri("tcp

1热度

1回答

如何使用Apache.NMS.ActiveMQ（C＃）将自定义属性添加到消息中？

我从C＃中的ActiveMQ开始。我将我的对象序列化为json并毫无问题地发送它。我会添加属性到我的消息，但我没有成功。我在几个网站上看到了setIntProperty（String name，int value），但是我没有在Apache.NMS.ActiveMQ（C＃）上找到它。这里我的代码： ActiveMQ mom = new ActiveMQ(); ISession sessio

3热度

1回答

如何从Apache ActiveMQ的NMS得到消息底层流手柄

背景： C＃WPF应用程序交谈JAVA服务器通过ActiveMQ的（Apache.NMS）运行在Linux上/ JSON（Newtonsoft.Json）问题： JSON消息大于85000个字节时导致LOH碎片可能的解决方案：代替读取第ËJSON作为Apache.NMS.ITextMessage（这是目前的情况下），获得底层的流处理和使用JsonTextReader 执行问题反序列化：这

0热度

1回答

故障转移传输协议无法处理消费者控制消息

作为AbortSlowConsumerStrategy的一部分，如果发现消费者速度较慢，但在消费者/客户端一侧，故障转移传输协议实现看起来不像消费者，Active MQ发送关闭消费者的命令处理这个Consumercontrol命令，它会失败，说：“错误：未知的命令 - 消费者控制..”;有没有更好的方式来中止消费者而不是接收错误？请注意，消费者在DotNet中使用Apache.NMS库。

0热度

1回答

为什么我的流正在被同伴关闭？

我有听的ActiveMQ的跺脚服务器上的目标（队列或主题，也没关系），并简单地以下控制台程序记录它接收到控制台消息： using System; using Apache.NMS.Stomp; using Apache.NMS; using Apache.NMS.Util; namespace StompTest { class Program { st

0热度

1回答

ActiveMQ：多用户连接到一个队列，但只有一个用户接收所有消息

我目前正在使用NMS来开发基于应用程序的ActiveMQ（5.6）。我们有几个消费者（exe）试图从相同的队列（而不是主题）接收大量数据。虽然所有的信息都传给了一位消费者，尽管我已经让消费者在收到消息之后睡了几秒钟。顺便说一下，我们不希望消费者收到其他消费者收到的相同消息。在官方网站中提到，我们应该设置预取限制，以决定在任何时间点可以向消费者流式传输多少条消息。它可以被配置和编码。我尝试过的

5热度

2回答

.Net NMS.ActiveMQ应该存储消息发送调用之间的会话和连接

我刚刚开始使用ActiveMQ的东西，并得到了几个问题。我应该使用ActiveMQ的我做了什么，现在发送消息： public class ActiveMQSender { private readonly Uri connectionUri; private readonly IConnectionFactory connectionFactory; priv