apache-nms

0熱度

1回答

我想從我的代碼（'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

0熱度

2回答

如何以long（datatype）的形式發送消息給activemq負載？

我正在使用.NET 3.5將消息發送到活動mq，並且我有一個從隊列中處理這些消息的java偵聽器。部首包含 userId - long type - string isAdd-bool 監聽期待有效載荷是數據類型的長。所以我應該在有效載荷中發送數據類型。這裏是我用來發送消息到活動mq的代碼。 string payLoad = "123"; IConnectionFactory fa

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）試圖從相同的隊列（而不是主題）接收大量數據。雖然所有的信息都傳給了一位消費者，儘管我已經讓消費者在收到消息之後睡了幾秒鐘。順便說一下，我們不希望消費者收到其他消費者收到的相同消息。在官方網站中提到，我們應該設置預取限制，以決定在任何時間點可以向消費者流式傳輸多少條消息。它可以被配置和編碼。我嘗試過的

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與RabbitMQ相合STOMP

我正在使用STOMP協議讀/寫消息到/從Rabbit MQ（3.6.5）隊列。我使用Apache NMS Stomp（1.5.4）作爲客戶端庫。使用NMS發送消息時，出現下列異常：輸入字符串格式不正確。的原因是，NMS預計日提交郵件ID含有在特定位置的數字。這是從NMS庫中的代碼： public void SetValue(String messageKey) { key =

5熱度

2回答

.Net NMS.ActiveMQ應該存儲消息發送調用之間的會話和連接

我剛剛開始使用ActiveMQ的東西，並得到了幾個問題。我應該使用ActiveMQ的我做了什麼，現在發送消息： public class ActiveMQSender { private readonly Uri connectionUri; private readonly IConnectionFactory connectionFactory; priv