nms

    0熱度

    1回答

    我試圖將消息發送到ActiveMQ的服務器我寫在C#.NET客戶端應用程序。我有我已經轉換成Zip流並嘗試發送的XML消息。 public IMessage SendMessage(string mqUri, string brokerUri, MemoryStream message, string username, string password) { Uri conn

    0熱度

    2回答

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

    -1熱度

    1回答

    我一直在使用netflow來收集n/w數據並將其轉儲到我的db中。 Netflow給我NoOfBytes轉移以及交通速度(bps)。但是,這似乎有不一致之處。 我的公式來計算基點是: (NoOfBytes * 8)/(end_time - start_time) sec 但是,對於我在網流已經收到了記錄,這並不持有。 以下是我的數據庫中的一些記錄。 **********************

    3熱度

    1回答

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

    0熱度

    1回答

    美好的一天, 我有一個關於Java中反射的問題。 我想用下面的構造方法實例化一個類PacketPlayOutPlayerInfo構造: public PacketPlayOutPlayerInfo(PacketPlayOutPlayerInfo.EnumPlayerInfoAction paramEnumPlayerInfoAction, Iterable<EntityPlayer> paramI

    0熱度

    1回答

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

    0熱度

    2回答

    我試圖訂閱通知服務和類似於(org.omg.CORBA.MARSHAL: Server-side Exception: null)!的消費者警報,但獲取編組錯誤。非常感謝,如果有人能幫我解決我失蹤或做錯的事情。 idls文件從NotificationIRP idls和使用jacorb-3.5 api。 NotificationConsumer.java import org.omg.CORBA.*

    2熱度

    1回答

    我想在Apache ActiveMQ中使用MVC作爲發件人應用程序中的消息隊列中,我有一個窗口服務內置C#作爲監聽器的Apache ActiveMQ。 但我在上面的監聽器端讀取消息時發生異常。 發件人MVC代碼。 public void GenerateMQMessages(EmailModel mail) { try { //// Crea

    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熱度

    1回答

    我使用的是當前的Apache.NMS 1.7.1和Apache.NMS.ActiveMQ 1.7.2。 我使用的是IndividualAcknowledge,所以我試圖保持加載消息的數量很低,因爲如果我有1000個消息加載而沒有加載它們,它會變得非常慢(它每次搜索所有消息的鏈表) 。 我有以下codesnippets: BlockingCollection<IMessage> _collectio