我尝试在使用MassTransit处理完队列中的所有消息后停止总线。我将并发消息限制设置为1，因为我的消费者需要一次处理一条消息。结果表明，在一条消息被消费后，总线将停止。}); }); 公交车起止时间： await bus.StartAsync();
await bus.StopAsync();
浏览 43提问于2019-05-08得票数 1
1回答
我阅读了关于如何在MassTransit中配置附加总线实例的文章。我的场景:我有两个个人NuGet包(例如，Notification和审核日志包)，每个包分别有消息契约和消费者，然后是MassTransit和他们各自注册的总线。这些包已在MyApi Application中使用，它还拥有消息契约和用户。和MassTransit的另一个总线注册到MyApi应用程序。
现在我不确定是否使用多总线或一辆公
浏览 3提问于2021-08-12得票数 0
回答已采纳
我正在测试消息消费重试机制，并测试如果在消息仍在尝试消费的情况下取消处理(停止总线)会发生什么。根据https://github.com/MassTransit/MassTransit/issues/780的结果，我相应地配置了总线，以便流水线可以在重试状态下停止。但是，它们移到了_skipped队列中，而不是NACKing消息。我不明白为
浏览 4提问于2021-08-25得票数 0
我计划实现消息总线，其中消息将在.Net核心应用程序中生成，但消费者应用程序将在安卓设备上运行，并使用Java语言编写。在最初的近似中，发布者应用程序将对消费者一无所知。Java平板电脑将订阅消息总线，接收消息，并从总线取消订阅。看起来我需要为每个Android平板电脑动态创建队列，将其绑定到扇出交换，并将消息发送到交换或类似的东西。对于.Net来说，MassTransit框架已经具备了所有
浏览 16提问于2021-11-22得票数 0
我目前正在构建一个使用MassTransit和RabbitMQ作为我的消息层的系统。我正在尝试找到一种方法，让一个消费者在总线上监听所有类型的所有消息。这是为了我们的审计日志框架，我们想要记录通过消息总线的所有事件。
在MassTransit中有没有办法做到这一点？
浏览 2提问于2015-12-18得票数 7
MessageType："PublishX“Type1ConsumerXType3ConsumerX
所有的消费者都必须立即捕捉消息，但同时在自己的内部消费。例如，队列中有100个"PublishX“消息。Type1ConsumerX消耗了30条消息(同步)，Type2ConsumerX消耗了50条消息(同步)，Type3ConsumerX消耗了100条消息(同步)。我<
浏览 7提问于2015-03-22得票数 2
回答已采纳
我有一个.net-core服务，它使用MassTransit监听队列。它接受一条消息，完成所有的工作，最后它应该使用另一个连接(不同的主机，登录等)发布不同的消息。我添加了第二条总线，如MassTransit MultiBus示例(https://masstransit-project.com/usage/containers/multibus.html)中所示services.AddMassTransit<ISe
浏览 34提问于2021-10-01得票数 0
回答已采纳
我试图在基于Azure服务总线的非常可靠的基于消息的系统中使用MassTransit。当发生消息处理错误时，MassTransit将消息移动到错误/错误队列。我知道我可以对消费者的政策进行重新尝试，我是。我要配置的是MassTransit尝试处理消息，如果发生错误，请放弃该消息，以便将消息返回到订阅的前端，以供另一个订阅者接收。这将增加服务总线上的交付计数，最终可能导致死
浏览 8提问于2022-02-16得票数 0
回答已采纳
我已经阅读了有关错误处理和故障的MT文档，并放置了一些代码来发布故障，并编写了一个故障使用者，以便在Polly重试一些次数后监听故障消息。我有一个队列消费者，它使用MassTranasit从RabbitMQ获取消息，然后通过Http api发送到云系统。我已经处理了所有可能的异常，还在Polly重试中包装了http调用，以防止短暂的网络错误。但这种方法的问题是，在重试耗尽后，消息实际上会从处理中丢弃。如果目标系统停机10小时(我们之前不知道这次停机，否则我将计划
浏览 14提问于2020-09-14得票数 0
回答已采纳
1回答
我正在使用使用RabbitMQ和MassTransit的pub/sub消息来集成几个RabbitMQ模块。大多数邮件订阅应该是持久的。但有些应该是暂时的。当消费者死亡时，消息不应被存储，已经排队的消息将被丢弃。
在每个模块中，我创建了一个带有两个接收端点的总线。一个被配置为持久和非自动删除。另一个被配置为非持久和自动删除。每个人都有自己的一组消费者。为什么MassTransit绑定消息交换到绑定到端点队列的端点交换？为什么不
浏览 1提问于2017-11-08得票数 0
我正在努力为MassTransit的内存中总线找到一个API，让我的测试知道所有的消息都已经被它们匹配的消费者消费了。如果我有一个像这样配置的总线： _bus = Bus.Factory.CreateUsingInMemory(cfg => cfg.ReceiveEndpoint("server.fax.inbound.received
浏览 23提问于2019-04-13得票数 0
我已经在我的StructureMap配置中使用ContainerScope配置了一个类X，但是由于某些原因，当应用程序最初启动并且MassTransit使用者使用初始消息时，它会创建实例，但是在为该使用者接收的后续消息中，使用者会被重新创建，而不是对象X(我希望每个接收到的消息都会创建一个新的实例)。我知道如果我用瞬态来配置它，它会起作用，但我只需要为整个消息处理过程创建该类的一个实例。
在这方面的任何帮助都将非常感谢。
浏览 7提问于2020-03-06得票数 0
我有一个消费者去Redis保存一些数据。设想的情况是：
当Redis脱机时，我尝试在其中持久化一些数据，它将在使用者中抛出一个异常(RedisException)，当这种情况发生时，我希望请求消息来维护订单到达的顺序，并一直使用该消息直到成功
浏览 2提问于2021-01-14得票数 0
1回答
我正在通过以下方式注册MassTransit消费者：在运行这一行之后到目前为止，我找到的所有例子都在这里结束，并指出这是您应该做的全部。不幸的是，对我来说，我的消费者从来没有被调用，消息只是堆积在队列中(最终超时并进入错误队列)。消息完全显示在使用者队列中(+我看到一个消费者通过RabbitMQ管理工具绑定到队列)
浏览 1提问于2014-02-26得票数 0
回答已采纳
的文档建议使用IEventHubProducerProvider ( MassTransit.EventHub nuget包的一部分)向EventHub发送消息。然而，大多数MassTransit文档建议，当发布来自消息使用者的消息时，开发人员应该使用"“来发布消息。在我的应用程序中，我希望在两个不同的上下文中托管相同的MassTransitStateMachine：
其中，它使用内存总线，它与其他生产者和消费者之间的所有</em
浏览 0提问于2021-01-18得票数 0
回答已采纳
2回答
我在C#项目中使用Masstransit。public static IBusControl CreateBus() return Bus.Factory
浏览 5提问于2017-08-02得票数 0
我在Azure函数中运行MassTransit 7.1.8，使用服务总线作为传输。当使用者首次抛出异常时，将在“我的服务总线”命名空间中创建两个主题：masstransit~fault (没有任何订阅)和masstransit~fault--mynamespace~myevent--my-subscription", message, default(CancellationToken)); catch (System.Exception ex) }
浏览 17提问于2021-05-21得票数 0
回答已采纳
如何使用MassTransit和MSMQ正确地设置具有多个订阅者(它们都接收已发布的消息)的发布者-订阅服务器体系结构。我读过、和，但仍然不知道该如何设置
页面上的MassTransit示例最接近我想要的内容，但它设置了<em
浏览 2提问于2013-06-19得票数 1
云服务器
ICP备案
对象存储
实时音视频
云直播
腾讯云开发者
