本來我有一個單一的RabbitMQ節點的工作就好了請求/響應客戶端的交互。 我現在改變爲一個集羣，並試圖運行同樣的請求/響應操作。它壯觀地爆炸。 我設置2臺主機作爲RabbitMQ的集羣的一部分。 我有這麼多麻煩，我回到使用masstransit sample code。 這似乎也有麻煩。我最終得到我的請求服務的重複異常： --- End of stack trace from previous
我想驗證傳入消息，在我的情況下使用FluentValidation，如果失敗，它應該立即返回。我看着http://docs.masstransit-project.com/en/latest/usage/observers.html，並在我的情況，我喜歡的 public class ConsumeObserver : IConsumeObserver
{
Task IConsu
MassTransit的新手，仍然在玩一些教程項目。我將會有一個服務可能會運行20分鐘，並且在完成時我需要做一些事情。因爲它可能需要很長時間，我不想跟隨請求/響應模式並等待響應，並阻止線程。我認爲我的另一種選擇是創建另一個隊列，供消費者在完成作業時發佈。我看過這篇文章：MassTransit3 how to make request from consumer，但我不知道如何實現這一點。我的項目，
一連幾天我有問題的TransactionScope。錯誤信息如下： MassTransit.Context.ServiceBusReceiveContext Consumer Exception Exposed System.Transactions.TransactionAbortedException: The transaction has aborted.
at System.T
我做了很多關於如何在masstransit中記錄數據的研究（在官方文檔，github的問題頁面和stackoverflow）（記住日誌功能從任何日誌實現中分離），甚至在masstransit的github着名示例中作爲Sample-ShoppingWeb，採樣訂房和星巴克我無法理解如何登錄應用程序數據... 我安裝MassTransit.NLog和波紋管配置我的車： var bus = BusCo
我有一個問題，是否有可能創建過濾器來防止消費一條消息？ 例如消息是： public class ProcessingTask : IProcessingTask
{
public int Id { set; get; }
public string ExternalId { set; get; }
public ProcessingTaskStatus Status
我需要測試使用MassTransit的訂戶。 下面是一個示例代碼： using System;
using MassTransit;
public class AnimalSubscriber : Consumes<Animal>.Context
{
public void Consume(IConsumeContext<Animal> message)
{
我無法弄清楚如何使用MassTransit 3.1.2和RabbitMQ 3.6.0發佈消息事務。我有一個基本場景，我將某些內容保存到數據庫，然後我想發佈一個事件。纏繞它System.Transactions.TransactionScope不工作，以前我完成已發送消息的範圍： using (var scope = new TransactionScope(TransactionScopeOpti