masstransit

    0熱度

    1回答

    所以我一直在嘗試使用內存中功能編寫一個測試公共交通的測試。我想知道人們的做法是等待消費者執行。在下面的例子中使用睡眠,或者我也嘗試了一個while循環,但不是任何一個迷,任何更好的想法?我基本上想檢查消費者是否被執行。 [Fact] public async Task SomeTest() { var busControl = Bus.Factory.CreateUsingInMem

    0熱度

    1回答

    當消費者連接到接收終端,唯一命名的交換和隊列創建如: bus-{MachineName}-{ApplicationName}-{Identifier} 這是什麼隊列/交換的目的是什麼?有沒有任何文件詳細說明這一點?

    0熱度

    2回答

    我有2個系統,一個用於發佈消息和其他消耗它們。兩者都使用Masstransit(使用RabbitMQ),並使用ASP.Net web api 2和OWIN(以及Autofac作爲IoC容器)來實現。 一切工作正常,如果我的消費者沒有依賴關係,,但是當我注入一個依賴到我的消費者時,消費方法永遠不會執行(在初始化期間沒有錯誤拋出)。 這是相關出版商代碼: //Startup.cs public cl

    0熱度

    1回答

    我正計劃在ASP .net核心應用程序中實施健康檢查中間件。 例如,要檢查數據庫是否健康,我打開並關閉數據庫連接。同樣,檢查MassTransit是否健康的最佳方法是什麼(即它可以連接併發送/發佈消息而沒有問題)?

    0熱度

    1回答

    我有一個消費者的泛型參數IEvent。此類型是所有消息的基本接口,並且IEvent的子接口具有其他一些屬性。我希望能夠訪問具有嵌套類型的所有屬性的原始消息,而不僅僅是IEvent範圍。這些屬性可以通過RMQ管理儀表板看到,我認爲應該有辦法將它們排除出去。

    0熱度

    1回答

    我想創建一個隊列與RabbitMq在哪裏我會發送一些消息在一邊,並在另一個應用程序接收。我'與下面的代碼這樣做: return ServiceBusFactory.New(x => { var uriString = string.Format(@"rabbitmq://{0}/{1}/{2}?prefetch={3}", host, virtualHost, queue

    -1熱度

    1回答

    我有一個現有的系統,通過MassTransit發佈消息到一些Azure服務總線主題名爲CompanyName.SystemName.Messages.SomethingGotUpdated。如何使用Rebus配置新系統作爲該特定主題的訂閱者,然後將所有消息發送到相應的IHandleMessages<SomethingGotUpdated>處理程序? 我查看了文檔,但無法真正弄清楚如何完成此操作。任

    1熱度

    1回答

    我想知道消費消息的最佳實踐。我已經閱讀了MassTransit文檔,並且正在尋找這方面的內容,但是我沒有得出任何結論。 我有一個api(託管公交車實例),正在發佈消息。這些消息是多種多樣的,因爲這個API不是微服務(購買,銷售等的消息)。 如何組織我的消費者/隊列? 一個隊列類型的過程?例如,一個用於購買,另一個用於銷售,這個解決方案可能涉及許多流程,我不確定它是否是一個好的解決方案。如果我想購買

    0熱度

    2回答

    我正在調查在公共交通中使用傳奇來編排跨多項服務的活動。這個傳奇的生命是短暫的 - 如果一切順利,不到2秒。 對於我的使用情況下,我想用請求/響應方式,從而使客戶端請求命令,佐賀處理該命令,通過一些狀態變化都按收到的消息,並最終響應第一命令發起了傳奇,在這一點上客戶收到迴應,並可以顯示傳奇的結果。 從我所看到的情況來看,在這一點上,上下文不再意識到最初的請求。我如何回覆以這種方式收到的消息?在處理第

    0熱度

    2回答

    可以動態設置預取計數參數嗎?這裏是我想達到的。我有隊列用戶的服務。我有觀察服務器資源(如處理器使用情況,RAM等)的機制。當這些資源用得很多時,這種機制會向服務發送通知。所以,當這個通知來了,我喜歡停止從隊列中檢索消息。它可以通過從隊列中取消訂閱來完成,但效率會很高?此通知到來時,可以動態設置預取計數爲1嗎?如果沒有,如何實現這種事情?我使用C#和MasstTransit作爲服務總線。