masstransit

0热度

1回答

当邮件被masstransit灭绝时，我用驼峰案例取代它们而不是Pascale案例

dynamic或对象来自消息的键入属性存储在骆驼案例中。考虑，我们有一个消息像下面 public class UserCreatedEvent { public string Message { get; set; } public string UserName { get; set; } public dynamic Payload { get; set; }

0热度

1回答

访问Docker RabbitMQ集群在Masstransit上失败

我已经用RabbitMQ托管了两个Docker容器（请参阅下面的Docker文件）。我使用rabbitmqctl join_cluster将两个RabbitMQ实例组合到一个集群中。两个RabbitMQ实例的集群名称是[email protected]。如果我使用rabbitmq://localhost:5673/作为连接URL，我能够与群集的单个实例进行通信。但是，如果我使用rabbitmq:

0热度

4回答

Masstransit无法从码头集装箱访问主机RabbitMQ

我使用docker支持创建了一个简单的.net核心控制台应用程序。正在关注 Masstransit代码无法连接到主机上的RabbitMQ实例。但是使用RabitMq.Client的类似实现能够连接到主机RabbitMQ实例。 Masstransit抛出 MassTransit.RabbitMqTransport.RabbitMqConnectionException：连接失败：[email pr

1热度

1回答

有什么方法可以在masstransit传奇中访问已发布事件的标题？

当我发布这样的事件时，有没有什么办法可以在saga中访问标题？ await busControl.Publish<IOrderCreated>(new { OrderId = dto.Id }, context => { context.Headers.Set(LogConstansts.Common.OperationId,Guid

1热度

1回答

Masstransit 3.5.7原因在Erlang进程和通道数泄漏

我们使用 masstransit 3.5.7 的RabbitMQ 3.6.5 我们的环境中运行〜2000个微服务。我们使用集群。我们正在经历渠道数量的泄漏以及正在使用的erlang进程的数量。在下面的图片中，你可以看到我们有46,000个频道。如果我们查看连接，我们会看到每个连接中有许多空闲频道。另外，也许和它有关系，我们可以看到erlang进程的数量在不断增加。有人可以分享一些信息，

0热度

1回答

Autofac＆MassTransit - 注册用户ObjectDisposedException

上下文：ASP.NET Core App（1.1）。我试图解决我已经注册的IRepository，当我需要一个消费者实例时，但它看起来像我收到ObjectDisposedException。我创造了我的呼唤了ContainerBuilder的.Build()方法自动激活总线工厂方法。 public IServiceProvider ConfigureServices(IServiceColle

2热度

1回答

带参数的MassTransit活动错误

我目前正在使用Masstransit和Courier模式。我设置了一个可能失败的活动，我希望能够订阅此故障并采取相应的行动。我的问题是，即使我可以订阅失败，甚至看到导致失败的异常，但我无法将任何参数传递给它。出于测试目的，supose我有以下活动： public class MyActivity : ExecuteActivity<MyMessage> { public Task

0热度

1回答

测试masstransit消费者

我想测试masstransit消费者我的消费者是这样的： public class FilePolicyEvaluationConsumer : IFilePolicyEvaluationConsumer { public readonly IFilePolicyEvaluationCore _filePolicyEvaluationCore; public readonl

1热度

1回答

MassTransit RequestResponse示例将响应移至.Net核心上的跳过队列

我将MassTransit Sample-RequestResponse sample移植到.net核心。为了托管.net核心服务，对示例做了一些小修改。虽然服务可以接收请求，但客户端并未收到响应，最终会在rabbitmq的ignore_skipped队列中结束。但是，在某些执行过程中，我收到了我发送的第一个请求的响应，并在此之后失败。这是什么根源呢？我们如何在MassTransit上实现Requ

0热度

2回答

IBusControl发布什么都不做，同时包装到另一个类

我正在努力与MassTransit，这是另一个棘手的问题，我还没有解决。当我直接调用发布方法时，一切正常，邮件发送到RMQ。但是当我用自己的方法封装这个方法并且在包装类的构造函数中注入总线时，它不起作用。消息根本就没有到达公共汽车。 using (var uow = new Wrapper(ctx, bus)) { var itemMsg = new ItemChangedMessa