masstransit

1熱度

2回答

Masstransit從石英作業死鎖IRequestClient.Request調用

我有一個通過Masstransit IRequestClient.Request方法調用調用業務服務的報告。如果這個報告是從UI（ASP.NET MVC控制器）構建的，一切正常，但是如果從Quartz .net作業方法構建相同的報告，調用永遠不會返回。下面是代碼示例： //client is an instance of MessageRequestClient class var resp

0熱度

1回答

MassTransit - 限制在多用戶設置中同時處理哪些消息

目前，我有一個Windows服務使用RabbitMQ處理來自Web應用程序的異步消息。該服務使用消息上的實體ID來查找需要處理的實體。該消息目前並未指出應該對實體執行什麼操作，因爲這已由內部操作日誌提供。爲了幫助轉向多種競爭的消費者設置，我正在考慮通過RabbitMQ實施MassTransit。我在看如何防止同一個實體ID同時在不同的消費者處理多個消息。 MassTransit中是否有任何內容可

0熱度

2回答

MassTransit傳奇狀態到實例狀態映射

我是新來的MassTransit，我似乎無法弄清楚它如何將我在傳奇（MassTransitStateMachine）上定義的狀態映射到相關SagaStateMachineInstance上的「狀態」屬性類。舉例來說，如果我有一個狀態機類三種狀態： public class MySaga : MassTransitStateMachine<MySagaState> { pub

0熱度

1回答

以消費方法向下轉發收到的消息

要限制消費者（和總線）的數量，我們嘗試在一個消費者（）/隊列中對一些處理進行分組。但是，當消費者將消息轉換爲正確的對象時，我會遇到問題。假設我有一個消費者應該處理兩種請求類型。 2個子請求類型派生自基類型，我將該消息作爲派生類型發送，Consumer方法將其捕獲爲基類型，但無法得出請求類型是派生類型之一的結論。我打算爲每個派生類型創建一個Custom Consume（）方法。從主（初始）Co

-4熱度

1回答

JSon異常自引用循環

我正在使用Mass Transit發送消息。 public class Node { public Node Parent; public string Name; public List<Node> Nodes = new List<Node>(); } public class Portfolio : MessageBase { public

1熱度

1回答

如何通過MassTransit和RabbitMQ發送各種命令類型？

我是使用消息代理的初學者。我們有一個有多種子服務的票務服務。主管服務通過Web API獲取請求並將其發送到子服務。任何請求都有一個標題，用於檢測命令類型（如保留，退款，可用性等）。我們使用json來序列化對象。現在，如何通過MassTransit從發佈商（例如我們的主管系統）發送各種消息類型（不同對象），消費者可以輕鬆使用它？一般來說，是否可以在MassTransit和rabbitMQ中發

0熱度

1回答

MassTransit ScheduleRecurringMessage vs ScheduleRecurringSend

我的問題是：爲什麼ScheduleRecurringMessage已過時？如果是這樣，我如何計劃發佈重複消息？ P.S新的ScheduleRecurringSend方法將發送而不是發佈消息。

2熱度

2回答

如何獲得發佈商中的事件響應？

我在C＃中使用MassTransit和rabbitMQ。我向消費者發送命令，讓他們進入消費者並執行所需任務並嘗試向發佈者發送響應。 using MyCompany.Messaging; using System; using System.Threading.Tasks; namespace MassTransit.Receiver { public class Regist

1熱度

1回答

MassTransit在Azure服務總線上提供什麼？

我試圖確定是否需要在Azure服務總線上使用MassTransit，或直接使用ASB。我不打算使用saga或中間件等高級功能，但需要一個支持命令和發佈/訂閱式消息的簡單ESB。關於選擇交通工具的MassTransit documention仍在開發中。看看ASB文檔，似乎Azure提供的不僅僅是一個傳輸。我沒有使用其他ESB的經驗，所以我不確定我需要的是什麼功能。我正在尋找一些爲什麼我應該使

1熱度

1回答

使用C＃中的Masstransit/RabbitMQ將消息發送到特定的通道/路由密鑰

我一直在研究基於消息傳遞啓動一些工作者角色的應用程序。這是我想要的應用程序的工作方式： Client sends a request for work (RPC). One of the worker roles accepts the work, generates a random id, and responds to the RPC with the new id. The wor