-
如何通过Autofac模块配置大众运输消费者
如何在Autofac模块中注册Masstransit使用者。 我有此代码: <pre><code> builder.AddMassTransit(configurator =& -
从/向Saga发布
我正在使用MassTransit Sagas。当传入事件(AccountCreatedInWebAppEvent)进行一些处理并开始发布时,它将开始 -
MassTransit存储库中消息重试尝试?
MassTransit重试策略允许我们设置重试尝试。在消费者方面,我们可以致电 context.GetRetryAttempt()</ -
MassTransit-等待所有活动完成,然后继续处理
如果我需要进行很多活动,是否会导致资源阻塞或请求超时? 这是我的情况: 我有一个api -
MassTransit实体框架审核存储SentTime不可用
我已经使用实体框架存储和SQL Server为MassTransit消息设置了审核。默认情况下,审核记录表具有以下架构 -
在状态机中路由清单的发件箱?
在我的一个状态机动作中,我创建了一个路由清单来执行一系列命令。通过调用完成 <pre><code>submits = -
定义MassTransit Consumer多久检查一次服务总线
我正在使用MassTransit框架来管理我在服务总线上的队列,它的工作正常,问题出在24小时之内,服务总线 -
在ASP.Net Core应用程序中将消息发送到MassTransit Saga
我在Asp.Net Core应用程序中有一个简单的传奇配置: <pre class="lang-cs prettyprint-override"><code>services.AddSingl -
Masstransit:在哪里可以设置RabbitMQ传递模式以使消息持久化?
我找到了一些旧的例子,但是它们都不起作用了,因为方法已经不存在了。看看: <pre><code>bus.PublishR -
中间件和消费者之间的共享范围
<strong>目标</strong>:<em>读取消息头并将其放置在有一定范围的依赖项(IHeaderData,它是键入数据)中, -
如何在完成“事件”时加入TransactionScope?
我想知道是否有一种方法可以挂接到当前正在运行的事务中,并在该事务完成时完成工作。 当前 -
如何使用SQS发送masstransit命令?
我可以使用此功能通过Rabbitmq发送消息 <pre><code> private void SendRabbitMqCommand(string queueName, object message) -
将依赖项注入IConsumer
是否可以注入IConsumer? 例如 <pre><code>public class UpdateCustomerConsumer : IConsumer<ITestMessage> { p -
在Greenpipes / Masstransit中使用Partitioner和RateLimit
我试图了解是否有可能在Greenpipes中结合使用Partitioner和RateLimiter过滤器。我现在拥有的以下代码无法按预 -
AutofacRegistrationExtensions.ConfigureConsumers(IComponentContext)按约定注册接收端点
我正在尝试按照约定<em>(在MT v6.0中)</em>注册接收端点,但是这样做时,永远不会调用其Consume()方法 -
在接收到的每个消息上设置多租户作用域值的预期MassTransit中间件构造是什么?
我正在将MassTransit与Autofac配合使用,并且需要一种查询租户ID的入站消息的方法,该方法将用于动态构造 -
与多个环境共享单个AmazonMQ?
我想将MassTransit与Amazon MQ(也许是Amazon SQS / SNS?)一起使用。创建MassTransit总线时,是否有一些方法可以 -
如何使用MassTransit.IConsumer <IList>?预取计数> 1
在MassTransit中,如何通过设置prefetchCount> 1来执行此类操作以消耗IList事件?DataSynchronizationConsumer正在使用 -
无法从接口转换为MassTransit事件使用者中的具体实现
我很难理解为什么我不能将消息中的接口强制转换为具体实现。最糟糕的是,它以前曾奏效。但我无法 -
在MassTransit中从传奇发布消息时,找不到消息传递实体引发异常
在将MassTransit传输设置为Azure Service Bus的情况下引发消息时,会引发以下异常并将错误放置在错误队列中 -
SqlConnection ExecuteAsync在Linux上挂起,但在Windows上挂起
ASP.Net Core 我比电话有代码 <code>var resp = await conn.ExecuteAsync("procedureName", sqlParams, commandType: Co -
在ConsumerDefinition
MassTransit似乎忽略了<code>EndpointName</code>文件中的<code>ConsumerDefinition</code>属性。我知道使用了ConsumerDefinit -
所有消息完成后,MassTransit发布消息
我正在使用MassTransit管理多个HTTP发布过程,并希望在所有HTTP发布完成后发布消息。使用Sagas可以做到这 -
使用masstransit将消息发送到Azure服务总线主题中的特定订户组
我是天青服务公交车和大众运输的新手。我正在寻找针对特定情况的解决方案。 我有一个包含多 -
MassTransit RabbitMQ间歇性地引发AlreadyClosedException(连接已处置)
在尝试发布到RabbitMQ时,我从MassTransit(5.5.5)中收到以下间歇性异常。 <pre><code>Already closed: The AMQP op -
MassTransit Azure总线PrefetchCount必须为1
将MassTransit与Azure Service Bus用作传输。我被迫始终将PrefetchCount设置为1,否则使用者将多次将同一条消息 -
未通过StructureMapConsumerScopeProvider设置的MassTransit使用者IContainer有效负载
我正在尝试为我的消费者实现MassTransit中间件,在那里我需要从IoC容器(使用StructureMap)中获取对象的实 -
使用者引发异常时,Masstransit控制台应用程序退出
根据文档:<a href="https://masstransit-project.com/usage/exceptions.html" rel="nofollow noreferrer">https://masstransit-project.com/ -
是否可以在MassTransit Saga中将不基于ID的消息关联起来?
是否可以将传入的消息与没有1或1的ID或属性相关性的传奇匹配?我正在考虑执行以下操作,但是<code>Corr -
使用MassTransit将消息发送到临时队列
在以下情况下,我无法直接响应MassTransit RequestClient的请求 <ul> <li>请求服务1实现<code>RequestClient</code>