masstransit

    2熱度

    2回答

    我正在使用Masstransit和RabbitMQ來使用隊列中的消息。任何人都可以告訴我如何處理隊列關閉或無法獲取消息時的異常?以下是我的設置: var busControl = Bus.Factory.CreateUsingRabbitMq(cfg => { var host = cfg.Host(new Uri(configManager.RabbitMqUrl), h

    0熱度

    1回答

    我在Topshelf Windows服務中運行Masstransit(使用rabbitMQ)。我如何強制停止頂部服務,每當有消費者即使有異常。來自FaultConsumer? 由於

    0熱度

    1回答

    我有許多服務器,每個服務器運行一個服務的單個實例/偵聽相同的隊列/端點(有意!)會產生Competing Consumer模式。 該解決方案非常棒,因爲它提供了負載平衡和高可用性,並且非常適合我的使用情況。 然而,我希望能夠實現的是能夠使各個節點脫機的方式而沒有任何影響。換句話說,一種能夠告訴節點完成對已經收到的任何消息的處理,但不消耗任何消息的方式(而不是僅僅關閉服務並且不得不管理終止任何正在處

    1熱度

    1回答

    您好enybody知道如何解決MassTransit中的以下問題:消費者獲取請求和響應,但響應沒有返回到client.Request。方法。我已經在ASP NET WEB API創建的項目和我已經通過IRequestClient接口來實現請求/響應通信: public class RequestResponseCommandProvider<TRequest, TResponse> :

    1熱度

    1回答

    我已經創建了一個基本的演示pub/sub應用程序,該應用程序在使用MassTransit的本地主機上工作。 我想實現的是發佈消息和所有訂戶應該收到消息。 目前,在我的環境中,我啓動了一個發佈者應用和兩個訂閱者應用。但是當我發佈消息時,訂閱者輪流收到消息。 我認爲扇出交換類型是默認的?但它適用循環模式。 我加 config.ExchangeType = ExchangeType.Fanout;

    2熱度

    1回答

    我有一個MassTransit傳奇狀態機(從Automatonymous.MassTransitStateMachine派生),我試圖解決一個問題,只有當我將端點配置prefetchCount設置爲大於1 問題在於'StartupCompletedEvent'已發佈,然後在saga狀態被持久保存到數據庫之前立即處理。 狀態機的配置如下: State(() => Initialising); St

    2熱度

    1回答

    我有一個環境,我只有一個應用程序服務器。我有一些需要一段時間服務的消息(比如10秒左右),我想通過配置消費者應用程序運行代碼的多個實例來處理這些消息來提高吞吐量。我已閱讀了「競爭消費者」模式,並認爲使用MassTransit時應避免這種情況。根據MassTransit文檔here,每個接收端點應具有唯一的隊列名稱。我正在努力瞭解如何將此建議映射到我的環境。 是否有可能運行N個消費者實例,每個消費者

    0熱度

    1回答

    我想記錄我在MassTransit中使用的每條消息。有沒有一種方法來實現全球攔截器,我可以處理收入消息或實現使用配置? 我現在的配置是這樣的: BusFactory = Bus.Factory.CreateUsingRabbitMq(cfg => { var host = cfg.Host(new Uri(AppSettings.RmqConnectionString), h => {

    1熱度

    1回答

    我想跟蹤我的消息使用內置接口CorrelatedBy<TKey>,但我不太明白:我應該自己初始化它,例如,在我的消息(命令)的構造函數中, ? public class RegisterCallback : IRegisterCallback { public RegisterCallback() { CorrelationId = Guid.NewGuid();

    2熱度

    1回答

    我正在嘗試在MassTransit v3中使用C#和RabbitMQ實現只發布總線,其中總線沒有使用者。這個概念是消息將被髮布和排隊,然後一個單獨的微服務將消耗隊列中的消息。看看this SO answer,必須指定接收端點,以便消息實際排隊。但是,這似乎是contradict the common gotchas in the MassTransit docs,其中指出If you need t