1回答
我正在构建一个演示应用程序，它遵循在ASP.NET核心应用程序中结合使用MassTransit和RabbitMQ和Autofac的文档：namespace MessageDemo }, new CancellationToken());这一切似乎都在工作-没有错误消息-添加了使用InMemoryTestHarness的演示单元测试，并且正在工作-我的RabbitMQ实例在管理器概述中注册已发布的消息
浏览 15提问于2020-05-20得票数 1
我通过铲子链接了rmq实例和azure服务总线，并使用masstransit发送/接收消息。我可以成功地将消息发送到rmq，并在服务总线中查看它，但无法使用masstransit接收消息。我认为这是因为有不同的消息签名。也许有人也有类似的经历。谢谢
浏览 5提问于2021-10-04得票数 0
有一个带有SQS的 MassTransit示例。“总线”被配置为使用SQS (x.UsingAmazonSqs)。接收端点是一个SQS，它反过来订阅一个SNS主题。此配置执行时不会出现错误，而Worker将被调用，并将消息发布到总线。然而，消费者类不会被触发，并且似乎消息不会最终出现在队列中(或者更确切地说，是主题)。waitUntilStarted: true);更新2：
当我查看sns订阅时，我发现第一个是通过aws手动创建和订阅的
浏览 4提问于2021-06-07得票数 1
回答已采纳
我正在使用MassTransit + RabbitMQ组合在Asp.Net核心应用程序中。ep.ConfigureConsumer<CreateProductsConsumer>(serviceProvider); });当我运行应用程序时，我得到了这个异常：
MassTransit.RabbitMqTransport.Topology.Entities.ExchangeEntity在将exchange绑定到接收端点之后，不应该使用IServiceProvider配置使用者</em
浏览 13提问于2020-03-05得票数 3
回答已采纳
1回答
问题是，所消耗的消息被传递到*_error_skipped队列，并且它不会完全消失。using System.Text;using GreenPipes;using MassTransit.Util;
浏览 1提问于2018-07-13得票数 2
回答已采纳
我试图在一段时间后没有收到消息时通知用户，使用MassTransit和RabbitMQ。如何从死信队列中检索消息？在下面的尝试中，该消息会立即添加到两个队列中，并且永远不会超时。
浏览 0提问于2019-03-27得票数 1
回答已采纳
我正在将应用程序从使用MT3与RabbitMQ转换为使用Azure，而MassTransit在Azure中配置队列的方式与使用RMQ的方式不同，而且文档在光明端()，我想看看是否还有其他人解决了这个问题
浏览 1提问于2016-10-31得票数 4
回答已采纳
因此，我们设置了一个非常大的预取数，并且该单个队列的使用者将负责根据某些消息属性向内存队列中的其他队列分配。其他后台任务将从内存队列中获取消息并处理它。为了避免消息丢失，在后台任务处理完消息之前，是否可以手动修改消息？
浏览 1提问于2022-02-23得票数 0
我是Masstransit的新手，我不知道如何配置我想要的方式。我在configureservices中找到了使用消息类型队列的代码： // MassTransit-RabbitMQ Configuration
services.AddMassTransit这就是说，消费者从同一队列中获取消息。 我的方向正确吗？
浏览 31提问于2021-09-02得票数 1
回答已采纳
我正在尝试实现一个错误使用者，它只从错误队列中读取，而不实际消耗和从错误队列中取出消息。非常感谢。
浏览 0提问于2019-03-01得票数 0
我有一个类似如下的消息约定：{}var message我知道如何使用，但我不能选择正确的位置来更改消息内容。
谢谢!
浏览 1提问于2021-09-14得票数 0
我已经在我的StructureMap配置中使用ContainerScope配置了一个类X，但是由于某些原因，当应用程序最初启动并且MassTransit使用者使用初始消息时，它会创建实例，但是在为该使用者接收的后续消息中，使用者会被重新创建，而不是对象X(我希望每个接收到的消息都会创建一个新的实例)。我知道如果我用瞬态来配置它，它会起作用，但我只需要为整个消息处理过程创建该类的一个实例。
在这方面的任何帮助都将非常感
浏览 7提问于2020-03-06得票数 0
在项目的StartUp中，我为MassTransit.ActiveMQ做了以下设置。但是当我运行时，它会为我创建两个队列，一个是event-listener，另一个是Generation。
浏览 1提问于2021-10-16得票数 1
回答已采纳
我使用MassTransit作为Asp.Net Core Mvc项目中的HostedService，下面的代码创建了对队列的订阅，但我找不到任何允许我订阅主题的参数或配置。
浏览 17提问于2019-07-24得票数 0
在过去，我在RabbitMQ中使用MassTransit。最近，我需要实现处理Amazon简单队列服务(发送和消费消息)的基础架构。选择MassTransit而不是本机工具，以防将来队列提供程序会发生变化。然而，我一直在为配置而苦苦挣扎(没有太多的文档，特别是针对MassTransit V7和SQS7的文档)。我想知道，是否可以配置MassTransit，使其在使用消息后将其从队列中删除？我的目标是实现一个windows服务，它将侦听队列，使用任何新消息，并在成功完成后
浏览 11提问于2021-07-02得票数 0
我有一些需要一段时间才能服务的消息(比如10秒左右)，我希望通过配置多个运行代码的使用者应用程序实例来处理这些消息来提高吞吐量。我读过关于“竞争消费者”模式的文章，并认为在使用MassTransit时应该避免这种情况。根据MassTransit docs ，每个接收端点应该有一个唯一的队列名。是否有可能让消费者的N个实例运行，每个实例都接收相同的消息，但只有其中一个实例实际上会对其起作用?换句话说，我们可以在多个队列而不是一个队列中实现“竞争消费者”模
浏览 3提问于2016-08-03得票数 2
回答已采纳
1回答
MassTransit的UseConcurrentMessageLimit显然限制了每个主机实例同时处理的消息数量，这与来自host.json的maxConcurrentCalls相同吗？要将同步函数调用的次数限制为n，是否应该设置最大扩展量限制* UseConcurrentMessageLimit or maxCurrentCalls =n
我可以通过MassTransit或Azure
浏览 6提问于2022-05-31得票数 1
回答已采纳
1回答
我使用MassTransit与Azure服务总线进行微服务之间的异步通信。我需要使用中间件使用过滤器从消息中获取元数据。
目前，我有几个“消费”不同消息的使用者，但它们都来自同一个接收端点。这些使用者中的每一个都有自己的"ConsumeFilter“(零，一个或多个)，它们是IFilter类型范围的筛选器，并且注册在每个使用者的"ConsumerDefinition”类中，其方法是.UseConsumeFilter(typeof(TFilter &l
浏览 5提问于2021-04-16得票数 0
回答已采纳
我正在为每个使用者实例寻找一种方法来接收通过RabbitMQ通过MassTransit发布的消息。情况是，我们有多个微服务，需要在通知时使缓存失效。Pub-Sub在这个实例中不起作用，因为每个服务实例将有5个与其代码相同类型的消费者，因此只有一个人会在传统的PubSub中接收消息。消息观察可以是一种选择，但这意味着消息永远不会被消耗，并且永远停留在总线上。提前谢谢。
浏览 2提问于2018-04-03得票数 4
回答已采纳
我正在努力为MassTransit的内存中总线找到一个API，让我的测试知道所有的消息都已经被它们匹配的消费者消费了。
浏览 23提问于2019-04-13得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
