Masstransit
是一个开源的分布式应用消息传递框架，用于构建可扩展的、松耦合的分布式系统。它基于消息队列的思想，提供了一种简单而强大的方式来处理应用程序之间的通信。
Masstransit的主要特点包括：
- 分布式消息传递：Masstransit允许应用程序通过消息进行通信，而不是直接调用对方的方法。这种松耦合的通信方式可以提高系统的可扩展性和可维护性。
- 支持多种消息传输协议：Masstransit支持多种消息传输协议，包括RabbitMQ、ActiveMQ、Azure Service Bus等。这使得开发人员可以根据具体需求选择合适的消息传输方式。
- 异步消息处理：Masstransit支持异步消息处理，可以将消息发送到消息队列中，然后由消费者进行处理。这种方式可以提高系统的响应速度和吞吐量。
- 可靠性保证：Masstransit提供了一些机制来确保消息的可靠传递，包括消息持久化、消息重试、消息死信队列等。这些机制可以保证消息在出现故障时不会丢失。
- 可扩展性：Masstransit的设计允许系统根据需要进行水平扩展，可以通过增加消息队列和消费者来提高系统的处理能力。
Masstransit适用于各种分布式应用场景，包括微服务架构、事件驱动架构、消息驱动架构等。它可以帮助开发人员构建可靠、可扩展的分布式系统。
腾讯云提供了一些与消息队列相关的产品，可以与Masstransit结合使用，包括腾讯云消息队列CMQ和腾讯云消息队列CKafka。CMQ是一种简单、可靠、可扩展的消息队列服务，支持多种消息传输协议。CKafka是一种高吞吐量、低延迟的消息队列服务，适用于大规模的消息处理场景。
更多关于腾讯云消息队列产品的信息，可以访问以下链接：
- 腾讯云消息队列CMQ：https://cloud.tencent.com/product/cmq
- 腾讯云消息队列CKafka：https://cloud.tencent.com/product/ckafka
相关·内容
在迁移到Masstrasit8.0.3之后，ScopeFilter确实允许响应并结束发送中的使用者进程(ConsumeContext.)方法。在我们的例子中，我们有一个带有中介设置的缓存作用域过滤器。在消费发送方法中有一个CacheScopeFilter，它检查特定请求是否在内存缓存中：
var cacheResponse = cacheService.GetCachedResponse(cacheRequest);
if (cacheResponse != null)
{
浏览 44提问于2022-08-03得票数 1
1回答
我正在尝试用Azure服务总线来设置MassTransit。我想使用DLQ，而不是依赖_skipped和_error队列，但我不确定是否做错了。
这是我的设置的简化版本：
services.AddMassTransit(busConfigurator =>
{
busConfigurator.AddConsumer<MessageConsumer>();
busConfigurator.UsingAzureServiceBus((context, serviceBusBusFactoryConfigurator) =>
{
ser
浏览 8提问于2021-10-26得票数 0
回答已采纳
几天来，我对TransactionScope有问题。错误消息如下：
MassTransit.Context.ServiceBusReceiveContext Consumer Exception Exposed System.Transactions.TransactionAbortedException: The transaction has aborted.
at System.Transactions.TransactionStatePromotedAborted.CreateAbortingClone(InternalTransaction tx)
at System.T
浏览 5提问于2016-04-28得票数 1
回答已采纳
正在尝试配置.Net核心服务以与AmazonMQ - RabbitMQ实例对话。这是我正在使用的配置：
cfg.Host(new Uri("amqps://b-mdefg-ff37-4e33-855c-577a0c749659.mq.us-westeast-2.amazonaws.com:5432/"), h =>
{
h.Username("MyUsername");
浏览 4提问于2020-12-30得票数 1
在MassTransit 5.2.0中，我使用ConfigurePublish中的UseSendExecute方法将头添加到特定的消息类型：
var bus = BusConfigurator.ConfigureBus((h,cfg) =>
{
h.ConfigurePublish(x =>
x.UseSendExecute<TestMessage>(p =>
{
p.Headers.Set("x-deduplication-heade
浏览 0提问于2019-01-15得票数 0
回答已采纳
我一直试图在NewRelic中为MassTransit设置自定义度量标准，类似于NServiceBus与NewRelic的工作方式。使用NewRelic 文档似乎很容易实现这一点。
到目前为止，我还没有在GitHub上检出GitHub代码，而是为MassTransit设置了一个简单的插装文件，但这只包含消息发送，但我确实希望收到消息，但我似乎找不到第一个与传输实现无关的拦截。
<?xml version="1.0" encoding="utf-8"?>
<extension xmlns="urn:newrelic-extension&#
浏览 6提问于2015-10-13得票数 0
回答已采纳
1回答
我尝试通过masstransit实现rabbitmq，如指令https://masstransit-project.com/usage/transports/rabbitmq.html#cloudamqp中所示。 但是总线(IBusControl)没有工厂方法。 Bus.Factory.CreateUsingRabbitMq MassTransit，MassTransit.RabbitMQ - 6.2.0版本。 你知道我忘了包括什么吗？
浏览 19提问于2020-05-02得票数 0
回答已采纳
我已经成功地设置、配置和运行了MassTransit (v8.0.3) JobConsumers示例，现在正在尝试定制到我的项目。修改后，在提交工作时遇到反序列化问题：
Newtonsoft.Json.JsonSerializationException: Cannot deserialize the current JSON array (e.g. [1,2,3]) into type 'MyNamespace.Foo' because the type requires a JSON object (e.g. {"name":"value"}
浏览 13提问于2022-06-10得票数 0
回答已采纳
当我试图使用MassTransit 3在Azure中运行我的应用程序时，我得到了以下错误
实体名称或路径不能包含“/”作为前缀或后缀。提供的值是'/profile.api‘。参数名称: entityName
唯一能看到前缀被添加到队列名称的方法是通过MassTransit。
奇怪的是，队列是在中以"profile.api“的名字创建的。
以前有没有其他人经历过这种情况？我不确定这是否是MassTransit的错误，或者我是否错过了配置的一个步骤。
下面是完整的堆栈跟踪。
谢谢。
ArgumentException:实体名称或路径不能将'/‘作为前缀或后缀。提供
浏览 0提问于2015-11-15得票数 1
回答已采纳
我正在尝试将对MassTransit和MassTransit的DLL引用从3.4.0下载到3.3.1。
我用nuget替换了所有实例，并验证没有更多使用AsmSpy引用的3.4.0实例( MassTransit和MassTransit都被引用为3.3.1)。
Reference: MassTransit
3.3.1.0 by MassTransit.RabbitMqTransport
3.3.1.0 by BusinessLogic
3.3.1.0 by Contracts
Reference: MassTransit.RabbitMqTransport
3.
浏览 6提问于2016-11-29得票数 0
回答已采纳
我正在升级到最新的Masstransit版本，当尝试使用文档中描述的最小消息发布原始消息json时，会生成以下错误：http://masstransit-project.com/architecture/interoperability.html {
"message": {
"value": "Some Value",
"customerId": 27
},
"messageType": [
"urn:message:MassTra
浏览 12提问于2020-11-27得票数 1
回答已采纳
我有一个利用MassTransit和RabbitMQ作为消息总线的ASP.NET项目，我正在尝试实现MassTransit Saga，我想使用Saga的ScheduleTimeout功能，这需要MassTransit.RuntimeServices (TimeoutService)。
然而，随着我逐渐了解到，MassTransit的NuGet安装并不包含RuntimeServices，这在我看来似乎很愚蠢，但是哦，好吧。
因此，我尝试将MassTransit.RuntimeServices和MassTransit.RuntimeServices.Database直接包含在我的项目中，这导致了许
浏览 2提问于2013-08-09得票数 0
我正在尝试使用新的IJobConsumer，但该作业从未运行过。 在我正在测试的项目中，Mediator工作得很好，就像普通的(短期的)消费者一样。我唯一做不到的事情就是IJobConsumer。我不确定我是不是配置错了。 我是这样配置MassTransit的： services.AddMassTransit(x =>
{
x.AddServiceClient();
x.AddRabbitMqMessageScheduler();
浏览 12提问于2021-02-01得票数 0
我使用的是MassTransit和RaabbitMQ，当我试图发送消息时，我会得到以下错误：
rabbitmq://localhost/FilesVersioning => An exception was thrown during Send
at MassTransit.Transports.Endpoint.Send[T](ISendContext`1 context) in d:\BuildAgent-02\work\aa063b4295dfc097\src\MassTransit\Transports\Endpoint.cs:line 116
at MassTransit
浏览 1提问于2014-03-26得票数 0
回答已采纳
我的应用程序版本: netcoreapp2.2
MassTransit包：
<PackageReference Include="MassTransit" Version="7.1.8" />
<PackageReference Include="MassTransit.AspNetCore" Version="7.1.8" />
<PackageReference Include="MassTransit.Extensions.DependencyInjection" V
浏览 2提问于2021-06-12得票数 0
为了使用SQS，我在.NET核心web应用程序(web )中使用了MassTransit。它在发布消息方面工作得很好。但是在我尝试添加一个消费者之后，我遇到了一个问题。 以下是我的代码 public static void UseMassTransit(this IServiceCollection services, MassTransitConfiguration massTransitConfiguration)
{
services.AddMassTransit(x =>
{
x.AddConsumer&l
浏览 38提问于2021-02-09得票数 0
回答已采纳
我一直在使用MassTransit，真的很喜欢它。但是，在默认情况下，它使用一些特定于MassTransit的JSON包装所有RabbitMQ有效负载/消息。这使得与非.NET服务交换消息变得困难。我知道MassTransit可以被任何语言解析，但是MassTransit是.NET特有的东西，在我的非.NET服务中，我希望避免添加特殊的逻辑来处理JSON生成的消息。
有没有可能使用不通过"MessageEnvelope“接口的MassTransit来序列化JSON消息，从而与非批量传输服务建立更好的互操作性？或者这样做会破坏大部分/所有的MassTransit功能？
浏览 2提问于2018-03-29得票数 8
我正在尝试找到一种很好的方法来序列化MassTransit消息(信封和所有消息)并将消息存储在MassTransit之外。然后，我希望能够使用MassTransit在某个时间点发送消息，而无需任何额外的序列化。有没有办法用MassTransit和RabbitMQ做到这一点。
浏览 6提问于2016-12-28得票数 0
回答已采纳
我正在从事Blazor Server .NET 5项目，它使用了一个很好的MassTransit 7.0.5-develop2976框架(顺便说一句，谢谢！)
我很好奇为什么MassTransit ServiceCollectionBusConfigurator 在执行.AddConsumer<T>()时不将用户添加到DI中。因此，我得到了“无法解决使用者类型.”的异常，如下所示。请看下面的解决办法。
例如，当我通过类似的ServiceCollectionMediatorConfigurator添加IConsumer<>类型时，它会执行此操作。
当MassTransit
浏览 4提问于2020-10-12得票数 0
回答已采纳
(跟进)
我使用的是MassTransit 7.1.4.0和RabbitMQ 3.8.7。
在对C#代码进行更改后，我会得到(下面详细的错误消息)。
Unhandled exception. MassTransit.RabbitMqTransport.RabbitMqConnectionException: ReceiveTransport faulted: localhost:5672/
对代码的更改
将关键字public添加到类定义中。
我试过了
在changes.Rename EndpointNameDeleting管理rebootstop启动RabbitMQ RabbitMq服务中撤消
浏览 5提问于2021-02-08得票数 0
回答已采纳
3回答
我有一个简单的出版商是用MassTransit做的。我正在间隔内发送消息，并能够使用.NET客户端使用MassTransit接收消息。但是当我试图观察Python中的一些东西时，它是无声的。有没有一种从Python或其他语言中使用MassTransit的方法？值得赞赏的例子。
出版商：
builder.Register(c => ServiceBusFactory.New(sbc => {
sbc.UseRabbitMq();
sbc.UseBsonSerializer();
sbc.UseLog4Net();
sbc.ReceiveFrom(&#
浏览 0提问于2014-01-27得票数 9
回答已采纳
在面向微服务的架构中，masstransit与restful webservices在微服务之间进行通信的用例是什么？
当然，在使用异步通信时，masstransit (MQ)有其巨大的优势。但是当有同步请求时，masstransit与restful服务相比有什么优势呢？
我知道这有点宽泛。
浏览 0提问于2018-01-17得票数 1
1回答
我目前正在使用MassTransit作为pub/sub。现在，我有了一个用例，我希望在工作队列场景中使用MassTransit，如RabbitMQ网站中所描述的那样
我已经阅读了MassTransit的文档，但找不到有关工作队列的内容。
在这个用例中可以使用MassTransit，如果可以，那么可以有人提供一个示例。
浏览 0提问于2018-05-04得票数 1
回答已采纳
从MassTransit 7.3升级到8遇到了以下问题：
在7.3.1.0版本中，MassTransit包使用加密方式序列化消息：
void UseEncryption(this IBusFactoryConfigurator configurator, ISecureKeyProvider keyProvider)
但是，在8.0.7中，此功能已移到包MassTransit.Newtonsoft中。
由于从版本8开始，MassTransit默认使用System.Text.Json，所以我们希望使用该序列化程序。但除了使用"MassTransit.Newtonsoft“之外，我还没有找
浏览 6提问于2022-10-24得票数 0
回答已采纳
我很难让MassTransit (v7.3.1)使用运行在Docker容器中的ActiveMQ Artemis2.19.0使用已计划好的事件来工作。所有事情都可以正常工作，但是不管我指定什么延迟，事件的发布都不会延迟。
我尝试过使用测试工具复制相同的用例，但是这里所有的东西都像预期的那样工作。
更新了，我为MassTransit添加了调试日志，以便更好地了解时间线。
下面是我的测试代码，使用测试工具进行一次绿色测试，使用ActiveMQ进行一次失败的测试。
using Automatonymous;
using MassTransit;
using MassTransit.ActiveMqTr
浏览 14提问于2022-03-08得票数 0
回答已采纳
我用MassTransit来对付RabbitMQ。在大多数情况下，它工作得很好，但是过了一段时间，消费者开始抛出一个S-错误警告：
MassTransit.Messages Warning: 0 : S-FAULT rabbitmq://<redacted>/iemr_ExistingRowCheck 62560000-56b4-0050-b40b-08d69864ff75 ieMR.BulkCopy.MissingRowImport.Queues.ExistingRowCheck
An established connection was aborted by the soft
浏览 0提问于2019-02-22得票数 1
回答已采纳
我将在我的项目中实现可观察性，这些项目在微服务环境中彼此并排工作。 我已经使用了MassTransit，并且我将使用MassTransit跟踪项目之间的通信。也许可以使用像Jaeger这样的工具来监控这些通信。 MassTransit中有没有支持它的工具或方法？
浏览 30提问于2021-08-09得票数 0
回答已采纳
我有一个项目，其中我使用MassTransit +城堡温莎+城堡温莎log4net设施。我想添加MassTransit log4net日志记录，但是这两种“日志机制”似乎是不兼容的，因为log4net = 1.2.10，MassTransit需要log4net > 2.0.3。有人有类似的问题吗？
浏览 1提问于2014-02-05得票数 1
回答已采纳
我在我的产品中使用MassTransit。我必须使用ActiveMQ。包含MassTransit.ActiveMQ包的该项目针对的是netstandard2.0。我不想改变它，但是这个包包含了net452和netcoreapp2.0的程序集。
MassTransit.ActiveMQ包是否有可能支持网络标准？
浏览 13提问于2019-04-08得票数 0
1回答
我正在尝试使用RabbitMQ队列连接两个服务。第一个服务将值推送到队列，第二个服务将其检索并进行处理。一切都很好，但是当第二个服务试图处理作业时，它会抛出异常。队列项保留在没有任何信息的JobAttempt队列中，使用者服务重试处理作业，但每次都抛出相同的异常。
异常
fail: MassTransit.ReceiveTransport[0]
S-FAULT rabbitmq://localhost/JobAttempt f0cb0000-1616-902e-edb0-08d97cd26cf9 MassTransit.Contracts.JobService.JobSta
浏览 11提问于2021-09-21得票数 1
回答已采纳
作为一名消费者，我一直在使用Masstransit作为我的项目。MassTransit服务将使用来自另一个服务的消息，而我构建的另一个服务目前运行在NestJS上，并使用RabbitMq发送消息。当我试图序列化Rabbitmq消息时遇到的问题，它包含以下基本属性：
但是，由于MassTransit随后将我的消息包装在一个接口中，所以我无法获得存储在属性上的值。它是用来回复RabbitMq消息的“回复到”地址。有什么办法让我得到这个价值吗？或者我如何回应应用“直接回复”功能的狂犬病消息？
更新1作为Chris的响应我尝试这样做：
Startup.cs
public void Configure
浏览 4提问于2021-01-05得票数 0
回答已采纳
我使用的是masstransit + activeMq(MassTransit.ActiveMQ 5.1.3版本)。所有这些都按预期工作，而不是错误消息。当意外异常发生时，masstransit会在错误队列中创建消息。问题是消息体是空的。修复本地问题后，如何将消息移回进行进一步处理？
浏览 0提问于2018-07-04得票数 0
我在RabbitMQ中使用massTransit。使用massTransit发布消息将为我的消息类型创建一个交换。而masstransit使用者将创建到交换的队列和绑定。太好了，让事情变得简单。
在介绍massTransit之前，我使用rabbitMQ的api来创建队列、交换和绑定。我会让发布者和消费者运行相同的设置代码。因此，无论谁先运行所有队列，无论应用程序的哪一部分先运行，都将创建交换和绑定。当在开发环境中运行时，这是非常棒的。
我想知道是否可以用massTransit实现类似的事情？
浏览 1提问于2016-12-23得票数 1
我在AzureSerivceBus中创建了一个名称空间。直接使用Azure API，可以创建主题并向其发送-接收消息.
现在，我希望能够使用MassTransit作为抽象层创建主题。这是因为对于本地安装，我们使用RabbitMq，而MassTransit提供了良好的抽象。现在，我们希望相同的代码能够无缝地移动到云(AzureServiceBus)，并能够执行类似的操作。是否可以通过MassTransit (即创建主题和订阅)来完成这个任务？
MassTransit的Azure文档非常有限，所以不确定它是否支持Topics。
有什么暗示吗？
浏览 1提问于2016-10-07得票数 1
回答已采纳
由于某种原因，我不能在我的消费者上使用重试。我遵循文档中的例子，我只是向我的消费者添加了一个简单的r.Interval<>，但是在build...not上它失败了。 services.AddMassTransit(x =>
{
x.AddConsumer<SyncConsumer>();
x.AddConsumer<SyncForcadoConsumer>();
});
services.AddSingleton(provider => Bus.F
浏览 28提问于2020-01-31得票数 2
回答已采纳
在请求响应模型(使用MassTransit 3.0.14)中，我遇到了MassTransit的问题。
TLDR;请求-响应在响应类型为List/IEnumerable时不工作。
在客户机中，我正在创建IRequestClient的实例：
var RequestObjects = busControl.CreateRequestClient<MyObjectsRequest, List<MyObject>>(
new Uri(configuration["MassTransit:ServerAddress"] + &
浏览 4提问于2015-10-29得票数 0
1回答
我正在使用MassTransit v7和运行在Aws Lambda上的Asp.Net核心，我想升级到v8。我想知道在无服务器环境中使用MassTransit的正确方法是什么。
我看到的问题是背景/托管服务以及MassTransit如何使用它们。根据我的理解，后台服务在Aws Lambda环境中不能正常工作，应该避免使用。
“常见错误”一节规定，公共汽车必须始终启动：
创建总线实例仅用于发送或发布消息时，必须启动该实例。不发动公共汽车可能会产生一些奇怪的副作用。每条总线，即使是没有接收端点的总线，都必须启动(并最终停止)。
随着对v8的更改，MassTransit似乎会自动为MassTr
浏览 11提问于2022-08-18得票数 0
当mt试图从队列接收消息时，我会得到以下奇怪的错误。
Guid应该包含带4个破折号的32位数字()。
at System.Guid.GuidResult.SetFailure(Boolean overflow, String failureMessageID)
at System.Guid.TryParseExactD(ReadOnlySpan`1 guidString, GuidResult& result)
at System.Guid.TryParseGuid(ReadOnlySpan`1 guidString, GuidResult& result)
at System
浏览 9提问于2022-12-01得票数 0
回答已采纳
在使用massTransit (8.0.8)之后，我得到了以下错误：
'RoutingSlipCompleted‘不包含'GetVariable’的定义，最好的扩展方法重载RoutingSlipCompleted string，Guid)‘需要一个'ConsumeContext’类型的接收器--这里是我的代码：
using MassTransit;
using MassTransit.Courier.Contracts;
using MassTransit.Courier;
public class CheckInventoriesConsumer: IConsu
浏览 15提问于2022-11-28得票数 0
回答已采纳
我正在为一个家庭作业创建一个程序，它使用一个接口来计算火车旅行的成本：
Train Class:
public class Train implements MassTransit {
public void getCapacity() {
int capacity = 100;
}//end get Capacity
public int getRoundTripCost(int leave, int return_time){
int cost = 0;
cost = (return_time - leave) * 100;
return
浏览 1提问于2012-10-26得票数 0
回答已采纳
当RabbitMQ关闭时，默认情况下(我认为) Masstransit尝试无限连接，并得到“guest连接失败: Broker不可达:RabbitMQ@localhost:5672/”错误。 RabbitMQ一上线，Masstransit就开始工作了。有没有什么办法可以限制重试的次数？因此，Masstransit将停止重新尝试连接RabbitMQ。
浏览 16提问于2020-07-03得票数 2
回答已采纳
我尝试过使用MassTransit.SerilogIntegration nuget，但看起来它的上一个版本是5.5.6。我使用的是MassTransit 7.1.4，当我安装这个Serilog时，我发现了一个异常，它找不到ILog接口。有什么方法可以在当前版本的MassTransit中使用Serilog吗？
浏览 5提问于2021-02-02得票数 0
回答已采纳
我正在尝试按照MassTransit设置的开始进行操作。我已经确认我已经安装了.net Core5.0。https://masstransit-project.com/getting-started/和观看视频Youtube.com/https://masstransit-project.com/getting-started/？v=nYKq61-DFBQ但当我运行以下命令时，它似乎运行正常，但不确定是否添加了任何内容。 dotnet new -i MassTransit.Templates ? 然后，我按照视频中的说明运行以下代码 dotnet new mtworker -n Wo
浏览 29提问于2021-06-21得票数 1
回答已采纳
1回答
我使用dotnet创建了新的webapi项目。我正在使用.net核心3.1版本使用ubuntu19.10。
这是我的proj文件：
<Project Sdk="Microsoft.NET.Sdk.Web">
<PropertyGroup>
<TargetFramework>netcoreapp3.1</TargetFramework>
</PropertyGroup>
<ItemGroup>
<PackageReference Include="MassTransi
浏览 6提问于2020-04-24得票数 2
1回答
我目前正在学习SQS/MassTransit，并想知道是否有一种通过MassTransit(如ApproximateNumberOfMessages)获取队列属性的方法。我知道我可以用AmazonSQSClient的GetQueueAttributesRequest来做这件事，只是想知道MassTransit.So far googling是否也能做到这一点。
浏览 7提问于2022-03-30得票数 0
回答已采纳
1回答
我的团队刚刚开始使用MassTransit，我们试图弄清楚单元测试IConsumer实现是如何工作的。到目前为止，我找到的所有示例都使用了NUnit，MassTransit文档并不完整。我们正在尝试使用XUnit和Moq来做我们的单元测试。 我知道我们需要设置MassTransit测试工具的一个实例，在NUnit中这是通过一个OneTimeSetup完成的，并复制我们应该在XUnit中使用IClassFixture。不过，我正在努力让它与测试工具一起工作。 我在MassTransit GitHub上看过Chris Patterson的ConsumerTest_Specs.cs示例，但是我很难
浏览 23提问于2019-04-12得票数 3
回答已采纳
2回答
我读过Udi的文章。
MassTransit支持分布式事务吗？(为了避免MassTransit上的重复问题，而不是通过代码手动检查)
浏览 7提问于2016-04-02得票数 0
回答已采纳
我在Azure函数中运行MassTransit 7.1.8，使用服务总线作为传输。当使用者首次抛出异常时，将在“我的服务总线”命名空间中创建两个主题：masstransit~fault (没有任何订阅)和masstransit~fault--mynamespace~myevent-- (有一个订阅Fault-MassTransit)。
Azure函数Startup.cs
public override void Configure(IFunctionsHostBuilder builder)
{
builder.Services.AddMassTransitForAzureFuncti
浏览 17提问于2021-05-21得票数 0
回答已采纳
我试图在基于Azure服务总线的非常可靠的基于消息的系统中使用MassTransit。当发生消息处理错误时，MassTransit将消息移动到错误/错误队列。我知道我可以对消费者的政策进行重新尝试，我是。我要配置的是MassTransit尝试处理消息，如果发生错误，请放弃该消息，以便将消息返回到订阅的前端，以供另一个订阅者接收。
我试图使用这个结合自定义断路器，立即中断时，处理错误发生。
这将增加服务总线上的交付计数，最终可能导致死字，但我们已经有了非基于masstransit的方法来处理这个问题。
那么，是否有一种方法可以禁用所有错误队列功能并放弃消息？
浏览 8提问于2022-02-16得票数 0
回答已采纳
1回答
我想测试MassTransit作为我正在做的项目的ServiceBus。我启动了一个新的控制台应用程序，并从Nuget获得了MassTransit。
我在项目站点()上找到了文档，并将代码复制到控制台项目中，但文档中的代码似乎没有更新。
首先，以下不再是配置器的一部分：
sbc.UseMsmq();
sbc.VerifyMsmqConfiguration();
sbc.UseMulticastSubscriptionClient()
当我注释掉它们并尝试运行时，它会抛出一个异常：
at MassTransit.Ser
浏览 1提问于2014-09-09得票数 2
回答已采纳
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
腾讯云开发者
