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回答

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

    2熱度

    1回答

    我有用於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回答

    我想從我的代碼('IntPub')中調用Apache ActiveMQ NMS版本1.6.0,該代碼必須在.NET 4.0環境的沙箱中運行,出於安​​全原因。創建沙盒的程序使我的代碼「部分可信」,因此「安全透明」,這似乎意味着它不能創建ConnectionFactory(請參閱下面的錯誤日誌),因爲NMS似乎是'安全關鍵'。下面是導致此錯誤代碼: connecturi = new Uri("tcp

    1熱度

    1回答

    我從C#中的ActiveMQ開始。 我將我的對象序列化爲json並毫無問題地發送它。 我會添加屬性到我的消息,但我沒有成功。我在幾個網站上看到了setIntProperty(String name,int value),但是我沒有在Apache.NMS.ActiveMQ(C#)上找到它。 這裏我的代碼: ActiveMQ mom = new ActiveMQ(); ISession sessio

    3熱度

    1回答

    背景: C#WPF應用程序交談JAVA服務器通過ActiveMQ的(Apache.NMS)運行在Linux上/ JSON(Newtonsoft.Json) 問題: JSON消息大於85000個字節時導致LOH碎片 可能的解決方案: 代替讀取第ËJSON作爲Apache.NMS.ITextMessage(這是目前的情況下), 獲得底層的流處理和使用JsonTextReader 執行問題反序列化: 這

    0熱度

    1回答

    作爲AbortSlowConsumerStrategy的一部分,如果發現消費者速度較慢,但​​在消費者/客戶端一側,故障轉移傳輸協議實現看起來不像消費者,Active MQ發送關閉消費者的命令處理這個C​​onsumercontrol命令,它會失敗,說:「錯誤:未知的命令 - 消費者控制..」;有沒有更好的方式來中止消費者而不是接收錯誤? 請注意,消費者在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回答

    我目前正在使用NMS來開發基於應用程序的ActiveMQ(5.6)。 我們有幾個消費者(exe)試圖從相同的隊列(而不是主題)接收大量數據。雖然所有的信息都傳給了一位消費者,儘管我已經讓消費者在收到消息之後睡了幾秒鐘。順便說一下,我們不希望消費者收到其他消費者收到的相同消息。 在官方網站中提到,我們應該設置預取限制,以決定在任何時間點可以向消費者流式傳輸多少條消息。它可以被配置和編碼。 我嘗試過的

    5熱度

    2回答

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