masstransit

    0熱度

    1回答

    dynamic或對象來自消息的鍵入屬性存儲在駱駝案例中。 考慮,我們有一個消息像下面 public class UserCreatedEvent { public string Message { get; set; } public string UserName { get; set; } public dynamic Payload { get; set; }

    0熱度

    1回答

    我已經用RabbitMQ託管了兩個Docker容器(請參閱下面的Docker文件)。我使用rabbitmqctl join_cluster將兩個RabbitMQ實例組合到一個集羣中。兩個RabbitMQ實例的集羣名稱是[email protected]。 如果我使用rabbitmq://localhost:5673/作爲連接URL,我能夠與羣集的單個實例進行通信。但是,如果我使用rabbitmq:

    0熱度

    4回答

    我使用docker支持創建了一個簡單的.net核心控制檯應用程序。正在關注 Masstransit代碼無法連接到主機上的RabbitMQ實例。但是使用RabitMq.Client的類似實現能夠連接到主機RabbitMQ實例。 Masstransit拋出 MassTransit.RabbitMqTransport.RabbitMqConnectionException:連接失敗 :[email pr

    1熱度

    1回答

    當我發佈這樣的事件時,有沒有什麼辦法可以在saga中訪問標題? await busControl.Publish<IOrderCreated>(new { OrderId = dto.Id }, context => { context.Headers.Set(LogConstansts.Common.OperationId,Guid

    1熱度

    1回答

    我們使用 masstransit 3.5.7 的RabbitMQ 3.6.5 我們的環境中運行〜2000個微服務。 我們使用集羣。 我們正在經歷渠道數量的泄漏以及正在使用的erlang進程的數量。 在下面的圖片中,你可以看到我們有46,000個頻道。 如果我們查看連接,我們會看到每個連接中有許多空閒頻道。 另外,也許和它有關係,我們可以看到erlang進程的數量在不斷增加。 有人可以分享一些信息,

    0熱度

    1回答

    上下文:ASP.NET Core App(1.1)。 我試圖解決我已經註冊的IRepository,當我需要一個消費者實例時,但它看起來像我收到ObjectDisposedException。 我創造了我的呼喚了ContainerBuilder的.Build()方法自動激活總線工廠方法。 public IServiceProvider ConfigureServices(IServiceColle

    2熱度

    1回答

    我目前正在使用Masstransit和Courier模式。 我設置了一個可能失敗的活動,我希望能夠訂閱此故障並採取相應的行動。 我的問題是,即使我可以訂閱失敗,甚至看到導致失敗的異常,但我無法將任何參數傳遞給它。 出於測試目的,supose我有以下活動: public class MyActivity : ExecuteActivity<MyMessage> { public Task

    0熱度

    1回答

    我想測試masstransit消費者 我的消費者是這樣的: public class FilePolicyEvaluationConsumer : IFilePolicyEvaluationConsumer { public readonly IFilePolicyEvaluationCore _filePolicyEvaluationCore; public readonl

    1熱度

    1回答

    我將MassTransit Sample-RequestResponse sample移植到.net核心。爲了託管.net核心服務,對示例做了一些小修改。雖然服務可以接收請求,但客戶端並未收到響應,最終會在rabbitmq的ignore_skipped隊列中結束。但是,在某些執行過程中,我收到了我發送的第一個請求的響應,並在此之後失敗。這是什麼根源呢?我們如何在MassTransit上實現Requ

    0熱度

    2回答

    我正在努力與MassTransit,這是另一個棘手的問題,我還沒有解決。 當我直接調用發佈方法時,一切正常,郵件發送到RMQ。但是當我用自己的方法封裝這個方法並且在包裝類的構造函數中注入總線時,它不起作用。消息根本就沒有到達公共汽車。 using (var uow = new Wrapper(ctx, bus)) { var itemMsg = new ItemChangedMessa