masstransit

    1熱度

    1回答

    我有一個問題,是否有可能創建過濾器來防止消費一條消息? 例如消息是: public class ProcessingTask : IProcessingTask { public int Id { set; get; } public string ExternalId { set; get; } public ProcessingTaskStatus Status

    3熱度

    1回答

    我需要測試使用MassTransit的訂戶。 下面是一個示例代碼: using System; using MassTransit; public class AnimalSubscriber : Consumes<Animal>.Context { public void Consume(IConsumeContext<Animal> message) {

    0熱度

    1回答

    xmlDoc中指出: 添加一個消息處理程序服務總線處理消息 的特定類型 但它並不需要端點名稱。它如何工作?我嘗試了這種方法,但沒有發生任何事。 在總線運行時動態添加處理程序有沒有可能?

    0熱度

    1回答

    消息使用者在總線啓動時或者每當相應類型的消息出現在端點上時僅創建一次? 我的意思是訂閱消息的這個方法: cfg.ReceiveEndpoint(host, "customer_update_queue", e => { e.Consumer<UpdateCustomerConsumer>(); });

    0熱度

    2回答

    我在學習MassTransit。我已經通過NuGet安裝了MassTransit.RabbitMQ 3.3.5版。我已經安裝了Erlang 18.0 *和RabbitMQ 3.6.3(* Erlang版本19.0對RabbitMQ 3.6.3不穩定)。我發現了一個「快速入門」的MassTransit程序here,並修正了一點點typeo後,讓它編譯。但是,當我執行該程序時,發佈的消息「YourMe

    1熱度

    2回答

    MassTransit的新手,仍然在玩一些教程項目。我將會有一個服務可能會運行20分鐘,並且在完成時我需要做一些事情。因爲它可能需要很長時間,我不想跟隨請求/響應模式並等待響應,並阻止線程。我認爲我的另一種選擇是創建另一個隊列,供消費者在完成作業時發佈。我看過這篇文章:MassTransit3 how to make request from consumer,但我不知道如何實現這一點。我的項目,

    1熱度

    2回答

    一連幾天我有問題的TransactionScope。錯誤信息如下: MassTransit.Context.ServiceBusReceiveContext Consumer Exception Exposed System.Transactions.TransactionAbortedException: The transaction has aborted. at System.T

    0熱度

    1回答

    我已閱讀了很多關於MassTransit並進行了實驗的文章。但是我有一個我不知道MassTransit適合與否的場景。如果有熟悉MT的人會在這件事上爲我提供建議,我將不勝感激。 1-我必須處理具有5種不同佈局或數據結構的CSV文件。 2-每個文件可能有一百萬行。 3-行應按順序處理(FIFO)。因爲順序很重要。 4-一條生產線由多個步驟組成,如從DB獲取相關信息,檢查,計算,分析和保存到DB。 5

    0熱度

    1回答

    我有一個使用webgardens的webfarm,我希望在從其他進程引發事件時通知每個進程,此事件主要用於更新內部緩存,例如,如果進程更新「客戶」所有其他進程應該得到通知。 每個進程創建一個總線與RabbitMQ,然後我設置一個名爲隨機的終端,我註冊我的消費者,這似乎工作,無論如何,在一天結束時,我發現裏面有很多死兔隊,流程。 我試圖使用臨時隊列來達到這個目的,但我不知道如何將事件發佈到總線上並讓

    0熱度

    1回答

    有一個新的包由克里斯帕特森,但我沒有找到任何使用的示例或一些文件尚未... 這個包是配置Masstransit與mongoDb! 任何人都知道如何使用或配置它? https://www.nuget.org/packages/MassTransit.MongoDb/