masstransit

    0熱度

    1回答

    我使用MassTransit編寫消費者並使用Azure服務總線作爲傳輸。 public async Task Consume(ConsumeContext<ISimpleRequest> context) { try { _log.InfoFormat("Strated working on {0}", context.Message.CustomerId);

    0熱度

    1回答

    消息消息過程中有什麼方法可以修改消息的中間件標題嗎? 正如我所看到的ConsumeContext上的Headers接口不提供任何方式來設置標題,有沒有其他方式來實現呢? 謝謝!

    1熱度

    1回答

    我正在使用MassTransit和Azure服務總線作爲傳輸。我創建了實現IAlert的IAlert和IAlertExt。 我試圖發佈兩條消息: busControl.Publish<IAlert>(new Alert(customerId)); busControl.Publish<IAlertExt>(new AlertExt(customerId)); 而寫的消費者來處理消息: pub

    1熱度

    1回答

    我使用MassTransit和Azure Service Bus作爲傳輸創建隊列。我不是在問消息的一生。如果沒有一個訂閱者不訂閱這個隊列,我需要知道隊列何時被刪除?

    0熱度

    1回答

    我創建了一個使用MassTransit和Azure服務總線作爲傳輸工具的應用程序。發佈,發送,檢索事件和命令 - 這一切都很好。但是現在我想創建訂閱者來檢索發佈者在用戶連接後發送的消息。怎麼做?我不想在連接之前獲取發佈商發送的所有消息。

    0熱度

    1回答

    我正在使用MassTransit 3.0與RabbitMq。我想知道我的隊列是否爲空,因爲如果需要從db中刪除臨時表。我無法弄清楚如何查看隊列是否爲空。 var inventoryBus = new InventoryBus(new RabbitServiceConfig()); inventoryBus.Instance.Start(); inventoryBus.Instance.Conn

    0熱度

    1回答

    我試圖從3.4.0到3.3.1下載對MassTransit和MassTransit的DLL引用。 我用nuget shell替換了所有實例,並驗證了沒有更多的3.4.0 AsmSpy參考實例(MassTransit和MassTransit總是被引用爲3.3.1)。 Reference: MassTransit 3.3.1.0 by MassTransit.RabbitMqTranspor

    0熱度

    1回答

    我試圖使用UseRetry和間隔設置使用MassTransit和Azure服務總線作爲傳輸。 消費者代碼: public async Task Consume(ConsumeContext<ISimpleRequest> context) { _log.InfoFormat("Strated working on {0}", context.Message.CustomerI

    1熱度

    1回答

    我試圖將消息從錯誤隊列移回到它起源的隊列。 爲此,我在錯誤隊列上創建了一個使用者,然後將其發佈到必需隊列中。 當我嘗試這樣做時,消費消息的一半被髮布,但另一半被髮送到Error_Skipped隊列。 我已經嘗試過許多事情沒有成功,所以它可能是簡單的,我失蹤了。 這裏是我的代碼示例: public class ClaimsMessage { public string Descripti

    3熱度

    1回答

    將MassTransit配置爲容錯以正確處理間歇性RabbitMQ連接問題或RabbitMQ完全關閉的正確方法是什麼?我在兩臺不同的機器之間建立了一個RabbitMQ集羣,並配置了HA,以便鏡像所有內容。我還有一個F5負載均衡器設置爲主動/被動模式,以便所有流量都定向到主節點,但是如果運行狀況檢查失敗,它將故障轉移到次節點。我希望在這種故障恢復之後的任何客戶端連接都能繼續成功,但我在這裏遇到了麻煩