masstransit

    0熱度

    1回答

    我試圖連接到使用使用MassTransit var bus = ServiceBusFactory.New(x => { x.UseRabbitMq(); x.ReceiveFrom("rabbitmq://admin:[email protected]<IP Address>/somequeue"); moreInitialization(x);

    1熱度

    1回答

    本來我有一個單一的RabbitMQ節點的工作就好了請求/響應客戶端的交互。 我現在改變爲一個集羣,並試圖運行同樣的請求/響應操作。它壯觀地爆炸。 我設置2臺主機作爲RabbitMQ的集羣的一部分。 我有這麼多麻煩,我回到使用masstransit sample code。 這似乎也有麻煩。我最終得到我的請求服務的重複異常: --- End of stack trace from previous

    0熱度

    1回答

    我想驗證傳入消息,在我的情況下使用FluentValidation,如果失敗,它應該立即返回。我看着http://docs.masstransit-project.com/en/latest/usage/observers.html,並在我的情況,我喜歡的 public class ConsumeObserver : IConsumeObserver { Task IConsu

    1熱度

    1回答

    在採樣ShoppingWeb的ShoppingCartStateMachine有這樣的配置,調度事件: Schedule(() => CartExpired, x => x.ExpirationId, x => { x.Delay = TimeSpan.FromSeconds(10); x.Received = e => e.CorrelateById

    0熱度

    2回答

    我想弄清Masstransit 2.9.9和RabbitMQ 3.4.3。我在服務器上安裝了RabbitMQ,並試圖從桌面獲取一個簡單的控制檯應用程序來發送消息。我創建了另一個管理員登錄 我不斷收到權限錯誤,總線不會初始化。 ACCESS_REFUSED - 使用認證機制PLAIN拒絕登錄。有關詳細信息,請參閱代理日誌文件。 當我查看日誌文件時,即使在我發送另一個登錄名時,它似乎也使用guest。

    0熱度

    2回答

    我一直在嘗試在NewRelic中爲MassTransit設置自定義指標,類似於NServiceBus如何與NewRelic配合使用。看來這很容易使用NewRelic .Net Custom Transactions文檔實現。 到目前爲止,從檢查出GitHub上的MassTransit代碼,我已經設法爲MassTransit組合了一個簡單的工具文件,但這隻包含消息發送,但我真的希望收到消息,但我似乎

    3熱度

    1回答

    這是我的整個代碼。我認爲測試應該通過,但是失敗。我(嘗試失敗)嘗試使用Consumer的一些重載。 using MassTransit; using NUnit.Framework; using System.Threading.Tasks; namespace MassTransitTests { public class Message { }

    1熱度

    1回答

    是否有任何DataBus庫可以插在MassTransit管道之上以允許發送大型有效載荷?理想情況下,我想要使用GridFS將它們存儲在MongoDb中。 我在尋找什麼是類似於NServiceBus數據總線特性的東西 - http://docs.particular.net/nservicebus/messaging/databus 提前感謝!

    0熱度

    1回答

    我想在Masstransit 3中註冊消費者和處理程序,但我無法使用IMessageConsumer接口。我如何讓MT3使用例如IHandle <>接收消息?

    0熱度

    1回答

    如何從masstransit服務總線配置創建虛擬主機? 我的意思是,例如,我將自己的應用程序部署到了一臺新PC上,並且它應該爲自己創建新的虛擬主機。 我試圖做到這一點是這樣的: var bus = ServiceBusFactory.New(sbc => { sbc.UseRabbitMq(); sbc.UseHealthMonitoring(10);