masstransit 相关问题

MassTransit是一个免费的,开源的,轻量级的Microsoft .NET框架服务总线。

使用 MassTransit 调用 DurableTaskClient 函数

我有一个 Azure Function,它使用 Orchestrator 从外部源同步产品。 直到今天,这个函数都是由 TimerTrigger 或 HttpTrigger 调用,并传递一个 InventoryId

回答 1 投票 0

MassTransit 交易发件箱再次投递

我希望在我的应用程序中将 MassTransit 用于各种用例。一种用例是处理应用程序中的“域事件”。在这个用例中,我有一些正在变化的业务数据......

回答 1 投票 0

如何使用 RabbitMQ 服务总线加过滤器实现 MassTransit 的请求/响应模式?

我正在使用 RabbitMQ 使用 IBusControl 对象和仅 1 个队列来实现 MassTransit 的请求/响应模式。 我们将运行 1 个请求发起者应用程序(当前是单元测试)并且

回答 1 投票 0

MassTransit 会使用其默认名称格式化程序创建主题/订阅,无论配置如何

使用公共交通。一切工作正常,并且消费/发布到预先创建的正确主题/队列。 但它正在创建额外的主题/订阅,而你却没有......

回答 1 投票 0

成功消费后从存储库中删除MessageData

我通过 RabbitMQ 传递大量数据并卸载队列,我使用声明检查模式将字节 blob 存储在队列本身之外。它工作得很好,但我有一个关于 cl 的问题...

回答 1 投票 0

大众交通支持空体RMQ消息吗?

我正在尝试使用 Masstransit 来消费一条带有空正文的消息,因为我只对它的标头感兴趣,但是当我发送带有空正文的消息时,它会直接路由到 _error 队列...

回答 1 投票 0

AWS 上的 MassTransit 队列

我已在 Azure 上成功使用 MassTransit,它为每个消费服务/应用程序生成一个“队列”,其中包含许多主题和订阅。 现在我已经将一些代码移植到 AWS,它似乎可以工作......

回答 1 投票 0

公共交通,未创建 saga 资源

我有两个服务,一个充当消费者,另一个充当生产者。以下是我对它们每个的配置。 生产者配置 服务 .AddSingleton(KebabCaseEndpointNameFormatter.Ins...

回答 2 投票 0

有没有办法使用 MassTransit API 在 SessionIdleTimeout 之前关闭 Azure 服务总线会话?

我们已使用以下配置成功激活会话: cfg.ReceiveEndpoint(端点.Item1, e => { e.RequiresSession = true; e.SessionIdleTimeout = TimeSpan.FromMinute...

回答 1 投票 0

当 Pod 关闭或重新启动时,公共交通取消消费者作业

我在 .Net 应用程序上使用公共交通时遇到以下问题。 我有一个类实现 IConsumer<> 接口并使用来自 RabbitMQ 队列的消息。该应用程序作为 pod 运行...

回答 1 投票 0

RabbitMQ MassTransit 批量竞争消费者

我已经设置了事件ExampleEvent的批量使用者,并将其设置为ConcurrencyLimit = 16、MessageLimit = 100、TimeLimit = 5秒并按ExampleEvent.GroupingKey字段分组。 这很好用...

回答 2 投票 0

具有粘性会话的 MassTransit 和 RabbitMQ

是否可以使用 RabbitMQ 作为 MassTransit 下的传输来使用粘性会话进行请求/响应? 我使用 Azure ServiceBus 作为传输进行以下工作,但我们想重新...

回答 1 投票 0

在 MassTransit 中实现持久存储和事务发件箱的示例或文档?

我正在使用 RavenDb,希望从持久存储和事务发件箱中受益。我试图弄清楚这是如何实现的,但我找不到任何文档并正在寻找

回答 1 投票 0

如何配置消费者生成的错误队列以使用与正常队列相同的路由键?

假设我有一个消费者: 公共类 TestConsumer : IConsumer { ... 配置为使用路由密钥: cfg.ReceiveEndpoint("test_queue", e=> {...

回答 1 投票 0

无法从 Masstransit Saga 事件更新实体框架核心关系

我无法更新我的传奇实例事件中的实体关系。 我可以为条目创建一对一行,但是当我再次回到 IssueLocation 状态时,它没有检测到...

回答 1 投票 0

由于 MassTransit,应用程序无法启动。他必须自己注册他的依赖项

我的消费者有这个构造函数: public QueueProcessingService(ILogger记录器,IQueueRepository存储库,ISendEndpoint端点) { _logger=记录器; _回购...

回答 1 投票 0

公共交通。处理反序列化异常

不久前,我开始使用Mastransit,并面临着拦截传入消息的反序列化错误的需要。不幸的是,经过几天的尝试,我...

回答 1 投票 0

MassTransit Kafka 和发件箱:没有此类配置属性:“schema.registry.url”异常

我已经使用 Kafka 和发件箱模式设置了 MassTransit var confluenceConfiguration = builder.Configuration.GetSection("Kafka").ToConfluenceConfiguration(); builder.Services.AddSingleton<

回答 1 投票 0

如何通过 Dapper 将 MassTransit 连接到 Postgres 来存储 Sagas?

我在任何地方都找不到工作示例,但在 MassTransit 的码头上有一个 MSSQL 示例(它具有 SqlClient 依赖项,并且不读取 Postgre 的连接字符串)。或者是

回答 1 投票 0

Azure Functions 使用 MassTransit 发布到 RabbitMQ

我当前正在运行一个 Azure Function,该函数使用 Masstransit 发布到 Azure 服务总线。为了便于调试,我希望能够在本地运行该函数并发布到本地...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.