easynetq

    0熱度

    2回答

    有什麼方法可以同步使用EasyNetQ從RabbitMQ消耗原始字節消息嗎? 我需要保證按順序處理和確認來自未以EasyNetQ格式發佈的系統的消息。我知道在單個線程的消費者運行,但IAdvancedBus接口只提供了一個方法以消耗原料的消息: IDisposable Consume(IQueue queue, Func<byte[], MessageProperties, MessageRece

    1熱度

    1回答

    嘗試使用EasyNetQ配置Simple Injector DI庫。什麼是實現這一目標的正確方法? 該項目包含NuGet軟件包'EasyNetQ.DI.SimpleInjector'。添加了如InjectionExtensions.RegisterAsEasyNetQContainerFactory(container);的代碼。但是,當試圖創建像Bus = RabbitHutch.CreateB

    1熱度

    1回答

    如果我發佈帶有確認(model.ConfirmSelect)的AKA basic.ack和強制性標誌。如果郵件未送達,我是否會始終在basic.ack事件之前獲取basic.return事件。 我想將所有basic.return消息添加到ConcurrentDictionary中,發佈後我會檢查消息是否在dicitonary中我會拋出一個異常,沒有隊列/路由存在,並刪除它,錯誤或成功。

    1熱度

    1回答

    RabbitMQ(由c#客戶端調用)是否能夠在隊列上分配工作並允許發佈者接收確認成功處理該工作的能力? 似乎應該可以不添加額外的隊列,但除非我遺漏了一些確認/確認並不告訴原始發佈者已成功處理消息。所以它無法知道它的所有工作是否得到處理。 我目前使用標準的兔子c#客戶端,但我知道easynetq也非常成熟,所以建議一個很好的方法來實現這一點,將不勝感激。

    0熱度

    2回答

    我正在使用EasyNetQ在兔子隊列中發送消息。 我有這樣 using (var bus = RabbitHutch.CreateBus("MyConnection")) { bus.Send("MyCodeName", "MyClass"); } 的連接的代碼是開放的,當我創建的公交車,但這個錯誤,當我送 的AMQP操作被中斷的消息:AMQP特寫原因由Peer發起,代

    0熱度

    1回答

    我有一個應用程序,一個asp.net mvc 4應用程序。我想用easynetq來使用rabbitmq。在我的本地計算機中,它完美地工作。但在Windows Server 2012的生產環境中,它不會發送任何消息。 我無法理解,爲什麼它不起作用。在日誌消息中,沒有什麼異常。 IIS和rabbitmq在同一臺機器上。 protected void Application_Start() {

    0熱度

    1回答

    時IClusterHostSelectionStrategy不工作我添加了新的RabbitMQ服務器&配置我的出版商連接字符串與 "host=PC1:5672,PC2:5672" var bus = RabbitHutch.CreateBus(connectionString, x => x.Register<IClusterHostSelectionStrategy<ConnectionFa

    1熱度

    1回答

    我想將每條消息保存到我的數據庫。 在RabbitMQ中,我直接創建一個消費者,以便在我的主/唯一交換中監聽主題「*」(任何事物)。 在EasyNetQ中,似乎我必須在每次創建新的Message類時在我的日誌項目中添加一行。我想避免這種情況,所以無論發送哪條消息,它都會在一個位置被拾取並保存到數據庫中,以備將來使用,而無需記住添加任何行。 我實現我自己的記錄 class MyLogger : IEa

    0熱度

    1回答

    我有一個使用EasyNetQ的.NET應用程序來監聽從另一個應用程序發佈的事件。應用程序使用SignalR將接收到的事件發佈到儀表板。 我正在使用章魚部署來部署我的應用程序,問題是每次部署應用程序的新版本時,我都停止接收公共汽車上發佈的所有消息(看起來我得到了其中的一些但不是全部) 。我已閱讀關於有多個用戶相同的ID,我猜這是問題。 我應該如何處理這個以避免「丟失」消息? 我該如何運行同一應用程序

    3熱度

    1回答

    隨着EasyNetQ v0.63.0.448,RabbitMqClient V4.0.2和RabbitMQ的服務器3.6.5當我嘗試創建像這樣總線... bus = RabbitHutch.CreateBus(new ConnectionConfiguration() { Hosts = new[] { new HostConfiguration() { Host =