如何在 RabbitMQ 的 MassTransit 中更改错误队列和交换的名称?
我尝试在一个简单的配置中抛出一些异常，并注意到创建了一些交换和一个与错误相关的队列: 交流: MassTransit:故障 MassTransit:Fault--ConsoleApp1:Program-YourMessage-- 队列: ReceiveEndPointQueue_error 如何更改或自定义上述命名? Program.cs: 公共静态类程序{
..
masstransit相关内容
Exchange 绑定在 MassTransit 与 RabbitMQ 和 SignalR 中不起作用
我已经使用大众运输rabbitMQ 和signalR 实现了一个.net 核心web api，我正在尝试使signalR 背板工作.我怀疑问题出在大众运输为我解决的交换绑定上，但我无法弄清楚我做错了什么导致这种行为. 我的目标是能够拥有另一个应用程序将调用的端点(现在我使用邮递员为此)，它将向所有客户端(js 端)发布消息，但每当消息发布并到达时由于没有绑定，因此交换没有任何反应. 在
..
轨道交通.使用在不同命名空间中定义的相同对象
首先，请原谅我的英语很糟糕.我将 MassTransit 与 Azure 服务总线一起用于微服务之间的异步通信.根据它们自己的定义，为了避免它们之间产生依赖关系，不同微服务之间发送的消息被定义在每个微服务中，即它们属于不同的命名空间.MassTransit 的自动管理导致队列和主题按对象类型进行管理，从而阻止消费消息的微服务接收微服务发布者发送的消息.同样的事情发生在同一个命名空间中具有相同属性但
..
如何覆盖 MassTransit 默认交换和队列拓扑约定?
正如 [在我关于 SO 的一个问题中] 所指出的(为什么 MassTransit 中的简单配置会创建 2 个队列和 3 个交换?)，MassTransit for RabbitMQ 会自动创建一定数量的队列并为给定的简单配置进行交换: 交换，所有扇出: ConsoleApp1:Program-YourMessage:耐用 VP0003748_dotnet_bus_6n9oyyfzxh
..
为什么 MassTransit 中的简单配置会创建 2 个队列和 3 个交换?
我创建了一个 MassTransit 快速入门程序来与我的本地主机 RabbitMQ 交互: 命名空间 ConsoleApp1{公共静态类程序{公开课 YourMessage{公共字符串文本 { 获取；放;}}公共静态异步任务 Main(params string[] args){var bus = Bus.Factory.CreateUsingRabbitMq(sbc =>{var host
..
带有 MassTransit 的 Kafka Producer - IBusInstance 尚未注册
我正在尝试使用 MassTransit 构建 Kafka 消费者 我有这段代码 var services = new ServiceCollection();services.AddMassTransit(x =>{x.AddRider(骑手 =>{Rider.AddProducer(“request", m => m.Message.RequestId);骑手.使用Kafka((上下文，k
..
使用 MassTransit SQS 时如何配置主题名称?
我使用 MassTransit SQS.我发现，当发布消息时，会出现这个问题: 用户无权执行:SNS:CreateTopic on资源 所以我需要创建主题的权限. 我通过要求管理员扩展权限解决了这个问题.可以创建此作品和主题.但是，主题名称似乎是根据类名称自动生成的.我可以以编程方式修改此行为吗(通过提供自我描述的主题名称). 这对于创建 FIFO 主题(需要以 .fifo
..
每次我发布消息时，只有一个消费者随机触发
我在示例项目中使用了 MassTransit 和 RabbitMQ.我只是尝试发布一条消息，然后由 2 个独立的消费者使用它.但每次只有一个消费者随机开火！有什么问题? 这是发送方方法 await _publishEndpoint.Publish(new ConsultantFinishedEvent(50)); Publisher 中应用程序启动中的此配置: #region 服务总
..
在 dot net core 应用程序中使用 RabbitMQ 在 MassTransit 中跳过队列
我有三个项目.一个是Dot net core MVC，两个是API项目.MVC 正在调用一个 API 来获取用户详细信息.当询问用户详细信息时，我通过 MassTransit 向队列发送消息.我看到跳过队列.第三个项目有消费者，即 API 项目. 我尝试为具有相同配置的演示制作另一个解决方案.运行良好. 下面是 MVC Razor 页面代码.. public async TaskOn
..
轨道交通.使用不同命名空间中定义的相同对象
首先，请原谅我的英语很糟糕.我将 MassTransit 与 Azure 服务总线一起用于微服务之间的异步通信.根据它们自己的定义，为了避免它们之间产生依赖关系，不同微服务之间发送的消息被定义在每个微服务中，即它们是不同命名空间的一部分.MassTransit 的自动管理导致队列和主题按对象类型进行管理，从而阻止使用消息的微服务接收微服务发布者发送的消息.同样的事情发生在同一个命名空间中具有相同属
..
MassTransit RabbitMQ 获取队列大小
如果队列中的消息数量大于某个阈值，我希望生产者不发送新消息.为此，我需要找出队列中当前有多少消息.有没有办法使用 MassTransit 框架来做到这一点? 解决方案 MassTransit 仅使用传输的功能(您没有提到).队列大小和其他度量通常是各种管理 API 的一部分.例如，可以在没有管理 API(这是一个插件)的情况下部署 RMQ 集群或实例，因此您无论如何都无法获得这些度量.
..
使用 RabbitMQ 的 MassTransit 中的连接事件
我想问一下 MassTransit 是否可以在 RabbitMQ 连接状态更改时通知客户端应用程序.我查了 IBusObserver，但是当 MassTransit 与 RabbitMQ 断开连接时没有信息. 这是一个重要的功能，因为在断开连接和重新连接的情况下，我必须发送带有应用程序当前状态的消息. 解决方案 您需要改用 IReceiveEndpointObserver 实例.
..
如何在 RabbitMQ 的 MassTransit 中更改错误队列和交换的名称?
我尝试在一个简单的配置中抛出一些异常，并注意到创建了一些交换和一个与错误相关的队列: 交流: MassTransit:故障 MassTransit:Fault--ConsoleApp1:Program-YourMessage-- 队列: ReceiveEndPointQueue_error 如何更改或自定义上述命名? Program.cs: 公共静态类程序{
..
如何使用Serilog记录MassTransit CorrelationId?
我正在使用MassTransit 3.5.7.我在启动总线之前添加了相关ID: MessageCorrelation.UseCorrelationId(x => x.CustomerGuid);MessageCorrelation.UseCorrelationId(x => x.Customer.Guid);MessageCorrelation.Us
..
未调用MassTransit故障使用者进行请求/响应
在MassTransit 3+中处理请求/响应模式的异常的最佳实践是什么?此处的文档提到如果消息中存在ResponseAddress，，则故障消息将发送到该地址，但是一个使用者如何在该地址接收消息?Bus.Request的ResponseAddress似乎是我无法控制的自动生成的MassTransit地址，因此我不知道如何访问在主要使用者中引发的异常.我想念什么?这是我的代码，用于使用Unity容
..
如何使用MassTransit测试工具通过带有构造函数依赖项注入的Activity(Automatonymous.Binders.EventActivityBinder)测试sagas?
为了使传奇代码保持简单，我创建了在触发传奇事件时执行的活动.现在，我想使用MT的测试工具为传奇创建测试.我还需要模拟这些活动的依赖关系.在MT 7.0.2中如何做到这一点? 这个问题类似于在这里找到的一个问题:如何使用MassTransit测试工具进行测试使用构造函数依赖注入的消费者吗? 下面是一些伪代码来举例说明我的用例: 公共类SomeSaga:MassTransitStateM
..
Exchange绑定在RabbitMQ和SignalR的MassTransit中不起作用
我已经使用masstransit rabbitMQ和signalR实现了.net核心Web api，并试图使signalR背板正常工作.我怀疑问题出在大众运输为我解决的交换绑定上，但我无法弄清楚这种行为到底有什么错. 我在这里的目标是拥有一个可以被另一个应用程序调用的终结点(现在我使用邮递员为此)，该终结点将向所有客户端(js端)发布一条消息，但是每当消息发布并到达时到交易所，因为没有绑定，
..
在MassTransit中，如果我为预定消息设置了TTL，是否包括初始延迟?
在MassTransit中，如果我计划将来发送一条消息(比方说3天之内)，并且我将消息的TTL设置为1天，那么该消息的实际TTL是否为4天?> 如果我将消息安排在将来的30天，则倾向于将TTL设置为30 + 1天，但是我不想这样做，以防我又不知道又增加了30天的TTL的. 解决方案 从查看
..
如何为AzureServiceBus配置RequiresDuplicateDetection主题
我正在尝试将 ASB 主题的 RequiresDuplicateDetection 属性配置为 true，但似乎没有遵守主 IServiceBusFactoryConfigurator 上的设置: var busControl = Bus.Factory.CreateUsingAzureServiceBus(cfg =>{cfg.Host("ASB_ConnectionString");cfg
..
代理脱机时是否可以保留消息?
是否有一种方法可以支持代理处于脱机状态，以便消息可以临时存储在光盘中，并在代理联机后尝试提交.这是为了在代理崩溃的情况下提供弹性.我尚未在文档中找到任何内容. 解决方案 MassTransit内置没有这样的东西.如果代理不可用，则无法发布或发送消息.
..