masstransit

0熱度

1回答

我正在使用Masstransit + RabbitMQ。我的一位消費者實現重試策略，並且我想知道是否有任何方法可以在消息進入錯誤隊列時獲取消息的重試次數？另外我想知道MT如何計數重試，因爲我沒有在使用RabbitMq服務器的消息頭中找不到任何相關信息。謝謝。

0熱度

1回答

MassTransit生產者需要60秒時間消耗事件

我有2個項目：一個MassTransit（Topshelf Windows服務）叫Service.Endpoints 一個控制檯應用程序客戶端試圖溝通與它叫做TestConsole。的總體要求是如下： TestConsole發送SolveProblemCommand Service.Endpoints消耗命令併發布ProblemSolvedEvent TestConsole消耗該事件。問題：

0熱度

1回答

MassTransit和MaxConcurrentCalls的行爲與預期不符？

我使用MassTransit作爲我的消息框架，在Azure Service Bus上運行。我正在WebJob中運行MassTransit（雖然我不認爲這很重要）現在我試圖讓MassTransit同時處理多個消息，因爲我正在處理單獨的消息需要一段時間來處理。所以爲了加速性能，我不希望每個消息都被逐一處理。我試着設置MaxConcurrentCalls爲例如30，但似乎沒有這樣做。消息仍然由我的消

0熱度

1回答

如何使用MassTransit由多個消費者訂閱一個隊列？

我使用Azure的服務總線運輸的MassTransit我試圖發送消息（命令）排隊： var sendEndpoint = await busControl.GetSendEndpoint(sericeUri); sendEndpoint.Send<ISimpleRequest>(new SimpleRequest(customerId)); 我也試圖用兩個用戶連接到這個隊列： var _bu

1熱度

1回答

MassTransit發佈到特定隊列

我已經成功地將2.x的MassTransit應用程序更新到3.x，並切換到我的傳輸RabbitMQ。我這樣做是爲了讓一對多消息傳遞正常運行，之前的開發人員認爲它可以與MSMQ協同工作，但是我發現它不起作用，通過閱讀我需要使用3.x和RabbitMQ的文檔變得清楚。我的應用程序在服務器上運行一個網站的多個實例，每個實例針對特定的客戶羣。我希望每個實例都發布到特定隊列，以便數據僅可用於特定實例的後端

0熱度

1回答

如果消費者關機，會發生什麼？（MassTransit）

我使用MassTransit編寫消費者並使用Azure服務總線作爲傳輸。 public async Task Consume(ConsumeContext<ISimpleRequest> context) { try { _log.InfoFormat("Strated working on {0}", context.Message.CustomerId);

0熱度

1回答

修改消費中間件的消息標題

消息消息過程中有什麼方法可以修改消息的中間件標題嗎？正如我所看到的ConsumeContext上的Headers接口不提供任何方式來設置標題，有沒有其他方式來實現呢？謝謝！

1熱度

1回答

如何配置消耗以使用不同的消息類型？（MassTransit）

我正在使用MassTransit和Azure服務總線作爲傳輸。我創建了實現IAlert的IAlert和IAlertExt。我試圖發佈兩條消息： busControl.Publish<IAlert>(new Alert(customerId)); busControl.Publish<IAlertExt>(new AlertExt(customerId)); 而寫的消費者來處理消息： pub

1熱度

1回答

什麼是Azure服務總線中的隊列生存期？

我使用MassTransit和Azure Service Bus作爲傳輸創建隊列。我不是在問消息的一生。如果沒有一個訂閱者不訂閱這個隊列，我需要知道隊列何時被刪除？

0熱度

1回答

檢索發佈者在用戶連接後發送的郵件（masstransit）

我創建了一個使用MassTransit和Azure服務總線作爲傳輸工具的應用程序。發佈，發送，檢索事件和命令 - 這一切都很好。但是現在我想創建訂閱者來檢索發佈者在用戶連接後發送的消息。怎麼做？我不想在連接之前獲取發佈商發送的所有消息。