masstransit专题提供masstransit的最新资讯内容,帮你更好的了解masstransit。
我已经将自定义类注册为<code>serviceCollection.AddScoped&lt;IMyClass, MyClass&gt;()</code>,以将其注入到我的Consumer
MassTransit <a href="https://docs.python.org/3/library/ast.html#ast.NodeTransformer" rel="nofollow noreferrer"><code>ast.NodeTransformer
我正在尝试创建一个将对所有消息类型执行的过滤器。理想情况下,您只需要注册一次过滤器,而不必
我将ConsumeContext注入MyClass构造函数中。 MyClass被注册为Scoped,并注入到MyCommandConsumer构造函数中。消费者
我正在尝试将MassTransit与现有的RabbitMQ服务器一起使用,该服务器具有一个直接交换并带有两个队列。但
! .net核心中的新手ALERT! 我有JWT的身份验证服务,我想将用户信息发送到.net core 3.1中的产品微服务。
是否有一种方法可以支持代理处于脱机状态,以便消息可以临时存储在光盘中,并在代理联机后尝试提
我正在尝试使用<a href="https://masstransit-project.com/" rel="nofollow noreferrer">MassTransit</a> 建立一个Kafka用户
我已经开始更多地利用masstransit的消息数据功能,并且需要管理商店中的消息数据-即删除旧数据。
我有一个.NET Core服务,它与2个单独的RabbitMQ服务器建立连接,其中一个由MassTransit管理,另一个由香草Rab
RabbitMQ支持消息优先级:<a href="https://www.rabbitmq.com/priority.html" rel="nofollow noreferrer">https://www.rabbitmq.com/prio
我正在使用MassTransit,并且具有这样的项目结构: <pre><code>Api1 (Publisher) - (Instance 1) Publishes PersonCreat
我正在与消费者使用Masstransit 7.0.0来处理RabbitMQ的消息。我观察到当使用者处理消息的速度很慢时,或者
我正在尝试将ASB主题上的<code>$answers = AnswerVersion::query()-&gt;with(&#39;answer&#39;) -&gt;whereHas(&#39;answer
我从MassTransit开始,我注意到当我在<code>Send&lt;T&gt;</code>中调用<code>ISendEndpoint</code>时,似乎呼叫者正在
使用<code>AddMassTransitHostedService</code>添加了运行状况检查配置,但是即使我像<a href="https://masstransit-project.
我正在使用配置有Asp.net core 2.2 API项目的MassTransit 6.3.2将消息发布到RabbitMQ。在论坛上的任何地方,我都
我正在尝试注册我的作用域使用过滤器: <pre><code>serviceCollectionConfigurator.UsingAzureServiceBus((context, cfg) =
<pre><code>=(IF(C2=&#34;Off&#34;;0;B2 * 0,075+D2 * 0,038)+E2 * 0,002) * 24 * 30,5 </code></pre> 发布者通过consolePublisher1名称空
我想在特定时间段内手动暂停特定的消费者合同。 <br/> 请注意,我<strong>不想</strong>要停止IServiceBus。<br