masstransit

0熱度

1回答

我使用MassTransit，以便在整個Azure的服務總線的消息路由我試圖使用MessageData（Azure的斑點）我有一個創建了一個「核心」庫總線，其中有代碼來設置端點。我有一個叫messages庫，定義了讓過去（由發送者和消費者使用）消息我有一個「消費者」誰需要得到的消息。我見過的人告訴我，我只需添加這樣的事情： cfg.ReceiveEndpoint("my_queue",

0熱度

1回答

使用MassTransit請求/響應對話擴展訂戶

我有一個使用Masstransit/RabbitMq在Web項目中使用的企業服務總線。我使用Masstransit的Request/Response模式來完成RPC over MQ。我在處理不同類型消息的總線中創建多個ReceiveEndpoint。 ESB使用自定義配置文件來創建多個總線，所以我可以以某種方式在邏輯上實現Qos，甚至在單獨的服務器上通過網絡分發消費者以增加或多或少的性能。最近

0熱度

1回答

如何隱藏MassTransit的接口/ RabbitMQ

我正在RabbitMQ中使用MassTransit。它工作得很好。但是，我注意到在RabbitMQ中，對於發佈的消息正在實現的每個接口，都會創建交換。這不是必需的，只是使RabbitMQ交易所混亂。所以，我的問題是：如何避免爲這些接口創建交換？有沒有可以照顧這個的一些屬性？

0熱度

1回答

如何使用作用域終身

我們可以設置Consume Observer使用以下方式創建MassTransit消息攔截器（觀察員） busControl.ConnectConsumeObserver(container.GetInstance<MessageConsumerInterceptor>()); 我想範圍生活方式適用於MessageConsumerInterceptor，這樣我可以填充/消耗或處理之前初始化一些

0熱度

1回答

MassTransit和RabbitMQ，使隊列在使用DI重新啓動時生存

我試圖強制RabbitMQ隊列在Rabbit服務重新啓動時生存，同時迫使它們在服務重新啓動完成後重新使用相同的名稱。我們正在利用我們的DI容器傳遞消息的消費者 return new List<Type> { typeof(Consumer1), typeof(Consumer2), typeof(Consumer3), typeof(Consumer4) }; 該集合，然後通過

0熱度

1回答

Masstransit。處理程序不確認消息

我有出版商： static void Main() { var bus = ServiceBusFactory.New(sbc => { sbc.UseRabbitMq(r => r.ConfigureHost(new MessageUrn("rabbitmq://localhost/test123"), c => { })); sbc

0熱度

1回答

Masstransit + RabbitMQ。在兩種不同的消息類型之間共享一個隊列

我有一個發佈者，它將消息發佈到rabbitmq：// localhost/test123隊列。一條消息具有TestMessage類型，另一條是TestMessage2類型。出版商配置： sbc.UseRabbitMq(r => r.ConfigureHost(new MessageUrn("rabbitmq://localhost/test123"), c => { })); sbc.UseL

0熱度

1回答

MassTransit傳奇堅持與實體框架和MySQL

我正在開發使用MassTransit（與RabbitMQ）和自動匿名的傳奇。我使用EntityFramework作爲我的商店引擎和MySQL作爲我的數據庫。每次我嘗試運行傳奇並將其狀態存儲在數據庫中時，EF和MySQL的組合都會引發異常。使用this示例應用程序並使用連接字符串連接到MySQL數據庫，可以重現問題。引發的確切例外是： System.Data.SqlClient.SqlExcepti

0熱度

1回答

發佈於CreateUsingInMemory總線崩潰應用程序

以下代碼僅會使應用程序崩潰，在調用發佈時，不會發生錯誤並且應用程序會關閉。我真正想做的是執行unittests，這段代碼只是爲了提供一個乾淨的例子的摘要。當我將相應的代碼作爲unittest運行時，我收到一條錯誤消息，指出線程正在中止。代碼使用的是MassTransit nuget包的3.5.6版本。任何人都可以看到我做錯了什麼？ using System; using System.Thr

0熱度

1回答

如何配置MassTransit以在發生故障時重試context.Publish（）？

如何配置MassTransit在失敗之前重試context.Publish()，例如，當RabbitMQ服務器暫時不可用時？