我有一個問題,是否有可能創建過濾器來防止消費一條消息? 例如消息是: 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的新手,仍然在玩一些教程項目。我將會有一個服務可能會運行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