masstransit

    0熱度

    1回答

    我使用MassTransit和Azure服務總線作爲傳輸。 考慮到Azure Service Bus的鎖定超時,我如何處理長時間操作(從1到18小時)?

    0熱度

    1回答

    我必須在傳入消息之前驗證傳入的消息。 要做到這一點,我需要從數據庫中請求一些數據。 繼教程之後,我創建了擴展方法來將我的規範+過濾器應用於使用者管道。事情是這樣的: public static void UseArticlesImportValidation(this IConsumePipeConfigurator configurator){} public class ArticlesI

    0熱度

    1回答

    我正在使用MassTransit與RabbitMq代理。我想知道是否有可能創建一個特定的隊列,但之後開始消費它的消息? F.E.基於某個標誌的價值。

    0熱度

    1回答

    我開始使用Masstransit sagas並創建了一個示例,如果我使用InMemorySagaRepository一切正常,但使用Redis存儲庫時,增加消息將移動到RabbitMq中的Consumer_Error隊列並顯示以下錯誤消息: '值不能爲空。參數名:鍵」,這堆棧跟蹤: at System.Collections.Generic.Dictionary`2.FindEntry(TKey

    0熱度

    1回答

    我正試圖找到一種序列化MassTransit消息(信封和全部)並將消息存儲在外部的好方法MassTransit。然後,我希望能夠在MassTransit的某個時間點發送消息,而無需任何額外的序列化。 有沒有辦法用MassTransit和RabbitMQ來做到這一點。

    0熱度

    1回答

    我有兩個不同的應用程序通過爲兩個應用程序中的每一個創建AppDomain在同一進程上運行。總線設置爲應用程序1是這樣的: builder.Register(c => { var inMemoryTransportCache = new InMemoryTransportCache(Environment.ProcessorCount); var bus

    0熱度

    1回答

    我正在使用Masstransit的請求/響應模式,我想指定死信的消息隊列名稱和其他與此隊列相關的配置(如果可用),我看到有一個UseDeadLetterQueue擴展方法到IPipeConfigurator類型,但是我必須配置的類型是ReceiveEndpoint方法中的IRabbitMqReceiveEndpointConfigurator,所以我不知道如何指定死信消息隊列,也許我試圖在錯誤的地

    0熱度

    1回答

    有關請求/響應模式的MassTransit 3+中處理異常的最佳做法是什麼? docs here提到,如果消息中存在響應地址,則故障消息將被髮送到該地址,但是一個消費者如何接收該地址的消息? Bus.Request的ResponseAddress似乎是自動生成的MassTransit地址,我無法控制,所以我不知道如何訪問主消費者中引發的異常。我錯過了什麼?這裏是我的代碼以註冊消費者和其使用故障消費

    1熱度

    1回答

    消息我有使用消息有清晰的認識:http://docs.masstransit-project.com/en/latest/usage/consumer.html 這些實現一次僅處理一個消息。 我需要批量批量處理多個郵件。

    0熱度

    1回答

    我們目前正在爲MassTransit轉換NServiceBus,我在請求/響應模式中遇到了一些困難。 在NServiceBus,我可以在Handler做回覆,並回到發送它的客戶端。 在MassTransit,看起來好像響應被送回,它是從,從而創建一個循環消耗的隊列...... 奇怪的事情,如果我創建使用InMemory總線,和客戶端和客戶端在同一臺機器上,我沒有問題。 我期待我的客戶搭上了迴應,而