easynetq

1熱度

1回答

我們計劃將RabbitMq用於我們的消息服務，我們將把所有消息請求發佈到RabbitMq持久隊列中。對於.Net客戶端，我們決定使用EasyNetQ，所以問題是如果RabbitMq服務器在發佈消息時發生故障，應如何處理？ - 我們應該發現異常並將消息保存到數據庫並重新發布預定作業嗎？ - 我們應該使用斷路器嗎？ - 還有什麼？我想聽聽你的經歷。

0熱度

1回答

與rabbitmq.client版本的噩夢

使用easynetq時，我遇到了rabbitmq.client版本的問題，但我不知道究竟是什麼原因造成的！我的解決方案包含一個WindowsService（exe文件）和多個庫項目，都是針對.NET 4.6.2構建的。在我exe.conf（服務可執行的）文件，我看到下面的條目： <runtime> <assemblyBinding xmlns="urn:schemas-microsoft-co

2熱度

1回答

在EasyNetQ中聲明具有特定名稱的請求/響應模式的響應隊列

在EasyNetQ中使用請求/響應消息傳遞模式時，我需要在請求隊列上發送消息之前聲明一個專用響應隊列（使用特定名稱）？我認爲框架在後臺聲明響應隊列，但我怎樣才能給這個響應隊列一個特定的名字？我沒有看到文檔中這方面的消息，在https://github.com/EasyNetQ/EasyNetQ/wiki/Request-Response

0熱度

1回答

EasyNetQ消息發佈程序模式

我正在爲EasyNetQ發佈封裝以將消息發佈到RabbitMQ。有大量需要發佈的消息。我是否應該使用模式來使用IBus發佈消息，還是應該將IBus類型var聲明爲類級別static var，並在應用程序結束時進行處理？ using (IBus bus = RabbitHutch.CreateBus(rabbitMQConnectionString)) { bus.publish("ss");

0熱度

2回答

死亡字體更改類型時，如何反序列化一封死信字母？

我想寫一個死信處理程序服務，從死信隊列中讀取消息，然後根據類型，內容等進行消息處理。在我的C＃應用程序中，我是使用EasyNetQ。我有一個名爲MyMessage的基本消息類型，然後是一些子類型。 EasyNetQ沒有序列化消息的問題，將它們發送到交換機，將它們從隊列中拉出，然後將消息反序列化爲原始類型。但是，如果我將我的死信處理程序中的AdvancedBus設置爲使用MyMessage類

0熱度

1回答

如何從EasyNetQ中的消息中獲取RabbitMQ死信頭信息？

這是一個後續到以前的問題，我問： How do I deserialize a dead lettered message when dead lettering changes the type? 我現在遇到的問題是，我不能看到額外的頭信息是RabbitMQ的增加，當一個消息是一紙空文。額外的頭信息在「x-death」之下，它們是計數，原因，隊列，時間，交換和路由密鑰。一旦EasyNetQ將消

0熱度

1回答

包含來自消費者的ACK的較小任務的任務

我正在處理一些POC project並嘗試解決以下問題。我有一個Publisher它發送一個消息隊列： bus.PublishAsync<IBaseScenario>(new TestScenario()) .ContinueWith(task => { if (task.IsCompleted && !task.IsFaulted)

0熱度

1回答

RabbitMQ - 當訂閱服務失敗並出現一些錯誤時如何停止發佈服務

我在C＃中有2個窗口服務。服務1將消息發佈到RabbitMQ隊列。服務2訂閱RabbitMQ隊列。服務2還連接到TCP服務器，並將它從RabbitMQ收到的消息發送到此服務器。我的問題是，是否有任何方法來阻止服務1發佈消息到隊列中，當服務2使用此消息由於某些錯誤而失敗（大多數是SocketException，如果它無法連接到服務器）。任何指針都會非常有幫助。如果需要更多信息，請讓我知道

0熱度

1回答

Spring Ampq類型名稱和EasyNetQ

我需要發送消息在C#微型服務與EasyNetQ和Java與Spring Amqp。問題是屬性消息，類型從Spring Boot Amqp在屬性__type__標題容器中，而在EasynetQ中預期來自名爲type的其他屬性。任何人都可以告訴我我需要自定義以讓它們交流嗎？ Spring Amqp : "Headers":{"__TypeId__":"com.fastdeliveryse

0熱度

1回答

專門連接到現有的RabbitMQ隊列

我有一位工作人員訂閱rabbitmq上的預先存在的隊列。出於冗餘目的，我們決定添加另一個連接到同一隊列的工作人員。是否有可能建立第一個工作人員獲取排隊專用連接的設置，以便第二個工作人員不能將郵件出列並因此充當備用工人？