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

1回答

NMS ActiveMQ忽略代碼中設置的預取限制

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

0熱度

1回答

無法提取體由於：javax.jms.JMSException異常：未能建立從字節體（無法提取發送ZIP文件的ActiveMQ）

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

0熱度

2回答

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

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

-1熱度

1回答

Netflow給出了bps的荒謬值

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

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

尋找一個Iterable的類來創建一個使用反射的構造函數

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

0熱度

1回答

故障轉移傳輸協議無法處理消費者控制消息

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

0熱度

2回答

CORBA通知訂閱（錯誤：org.omg.CORBA.MARSHAL：vmcid：0x0次要代碼：0完成：否）

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

2熱度

1回答

使用Spring.net的ActiveMQ和.NET的複雜類型消息不工作

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