在我们的分布式系统中，我们正在迁移到masstransit。 我们的集成合作伙伴在我们的系统上创建订单，并获得Order_Id。订单处理完成后，我们将发布一条消息(OrderStatusChanged)，其中包含Order_Id、Status ...等 然而，通过发布消息，我们所有的合作伙伴都会收到此消息，即使它只针对其中一个合作伙伴我们能想到的唯一解决方案是为每个集成的应用程序创建</em
浏览 6提问于2019-02-27得票数 0
回答已采纳
我正在尝试创建过滤器来填充使用者中的correlationId，并在发送的消息中添加这个correlationId。但是，我相信，由于它是多总线的上下文在2配置的总线之间是不同的，是否有任何方法使这个工作。下面是其中一个过滤器的示例： IFilter<Send
浏览 5提问于2022-11-02得票数 0
Masstransit Saga :在两个不同的saga工作流中有一些相同的事件(消息)，我们如何使用saga中的上下文过滤器来根据某些条件过滤命令/事件(消息)？
浏览 0提问于2019-08-30得票数 1
如果我将消息发送到一个启用会话的队列中，并且每个消息都有一个sessionID，那么我是否可以将使用者配置为只接收sessionID = X的消息。
浏览 5提问于2022-05-19得票数 0
我使用的是masstransit + activeMq(MassTransit.ActiveMQ 5.1.3版本)。所有这些都按预期工作，而不是错误消息。当意外异常发生时，masstransit会在错误队列中创建消息。问题是消息体是空的。修复本地问题后，如何将消息移回进行进一步处理？
浏览 0提问于2018-07-04得票数 0
如果消息是从不同的消息发送源(本例中为MassTransit客户端)发送的，那么RabbitMQ如何从RabbitMQ中提取消息？
这些消息共享相同的C#消息契约，并作为json进行序列化。我收到的当前错误是masstransit解析错误..。
浏览 4提问于2015-02-12得票数 5
我使用MassTransit和Autofac，需要一种方法来查询租户Id的入站消息，该Id将用于动态构造连接字符串。因此，合乎逻辑的步骤如下：
消息使用者由容器解析，容器使用每个消息作用域组件相应地构造依赖项。MassTransit有一个如何创建消息过滤
浏览 6提问于2019-12-10得票数 0
回答已采纳
更新：问题中的默认队列是我正在研究的MassTransit实现的一部分，表示问题没有意义。
我想我真正想知道的是:默认队列是瓶颈吗？我
浏览 0提问于2015-07-24得票数 0
回答已采纳
MassTransit指出，我们应该为消息契约使用接口：
使用POCO而不是接口的缺点是什么?在使用MassTransit</e
浏览 2提问于2017-06-05得票数 24
1回答
我看到的问题是背景/托管服务以及MassTransit如何使用它们。根据我的理解，后台服务在Aws Lambda环境中不能正常工作，应该避免使用。“常见错误”一节规定，公共汽车必须始终启动：
广告。1)接收http请求和发布消息的API应用程序。首先，它不应该
浏览 11提问于2022-08-18得票数 0
1回答
首先，请原谅我的英语，这很糟糕。我使用MassTransit与Azure服务总线进行微服务之间的异步通信。我需要使用中间件使用过滤器从消息中获取元数据。目前，我有几个“消费”不同消息的使用者，但它们都来自同一个接收端点。这些使用者中的每一个都有自己的"ConsumeFilter“(零，一个或多个)，它们是IFilter类型范围的筛选器，
浏览 5提问于2021-04-16得票数 0
回答已采纳
下面是在ASP.net Core6.0API中开发的一个示例POC，它使用MassTransit和RabbitMQ来模拟使用MassTransit使用者的简单发布/订阅。然而，当代码被执行时，它会在RabbitMQ中创建2个交换和1个队列。publishEndpoint.Publish<OrderDetails>(orderDetails);
}正如突出显示
浏览 11提问于2022-09-15得票数 0
我已经创建了一个Masstransit发布过滤器，它根据访问者提供的信息创建一个消息头。 我希望在处理过程中在访问器中设置一些值，这些值将由发布筛选器拾取。我对过滤器的理解是，它们是有作用域的，因此，任何发布的消息都将创建一个新的DI作用域。这意味着我在发布消息之前设置的值将不会出现在筛选器<
浏览 22提问于2021-10-27得票数 0
回答已采纳
我一直试图在NewRelic中为MassTransit设置自定义度量标准，类似于NServiceBus与NewRelic的工作方式。使用NewRelic 文档似乎很容易实现这一点。到目前为止，我还没有在GitHub上检出GitHub代码，而是为MassTransit设置了一个简单的插装文件，但这只包含消息发送，但我确实希望收到消息，但我似乎找不到第一个与传输实现无关的拦截。，我已经更新了新的包，所以我可以在ReceivePipe<em
浏览 6提问于2015-10-13得票数 0
回答已采纳
我在RabbitMQ中使用MassTransit。按照自定义中间件的official documentation page上的示例，我尝试在消息消费管道上创建一个过滤器，该过滤器将根据特定条件过滤出一些消息。我的过滤器看起来像这样： public class MyCustomFilter<T> : IFilter<T>
where T : class, Consume
浏览 15提问于2020-03-16得票数 0
回答已采纳
我正在尝试实现一个错误使用者，它只从错误队列中读取，而不实际消耗和从错误队列中取出消息。 }); await _notificationsClient.Slack(messag
浏览 0提问于2019-03-01得票数 0
正在尝试支持从http call W3C -> publisher -> http调用中传播->跟踪上下文traceId和spanId属性(因此它们现在出现在日志/seq中，但我们正在使用Dynatrace)，但我是否无法在这里找到任何现成的信息：我可以找到这个例子作为OpenTracing：的一个例子
作为NServiceBus：的参考除非有人能提出已经存在的</em
浏览 9提问于2020-05-18得票数 2
回答已采纳
1回答
因此，我有一个具有几个不同的“后端”asp.net核心web的体系结构，我正在使用Masstransit和rabbitmq来促进容器间的通信。使用MassTransit，服务需要它们之间的某种契约(只是简单的类)，如果系统部署在本地或服务器上是可以的，但是对于码头容器，这已经被证明是一个问题。我已经尝试谷歌了很多，但似乎有非常少的asp.net核心，特别是masstransit，结
浏览 2提问于2020-05-02得票数 1
回答已采纳
我正在设置一个消息队列，其中消息消费可能会偶尔失败一段时间(例如，由于网络停机)，在这种情况下，我希望在经过一段时间后重试。这在名为的MSMQ的WCF binding和名为的NServiceBus中均可用。在MassTransit中有类似的东西吗？
我在MassTransit文档中找不到这个问题的答案。我能在论坛上找到的最接近答案的是，它建议答案是否定的，但提供了
浏览 0提问于2014-07-02得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
