我想在将saga和订阅数据存储到数据库之前操作它，所以我实现了它们的两个接口，如下所示。;using Newtonsoft.Json;{ } }} <
浏览 24提问于2019-05-24得票数 1
回答已采纳
我正在配置一个总线，我需要配置Rebus持久化sagas的方式。我会在MongoDB中使用官方的C# Mongo驱动程序1.10版本来保存sagas，因此我正在编写以下内容：public static void StoreInMongoDb(this StandardCo
浏览 1提问于2016-02-01得票数 1
回答已采纳
Hellooo迷们，我们已经使用Rebus 0.84 aka 1.0很多年了，现在转向了4.0版本的&它在实现和性能方面似乎有了很大的改进，但是在实现处理程序的过程中遇到了一些问题。"); }; .CreateBus() }现在，如果我用rebus 4.0
浏览 1提问于2019-05-13得票数 1
回答已采纳
我希望能够为Rebus编写自定义中间件，它将环绕消息处理程序:在每个处理程序之前和之后执行，而不管消息类型如何。对于Rebus来说，这是可能的吗?如果有，我该如何做？浏览Rebus的源代码，我认为应该是可能的，因为库非常整洁地围绕着IPipeline的概念构建的，具有可定制的“步骤”。但是，虽然它看起来应该很容易添加自定义步骤，但我找不到任何公开
浏览 0提问于2019-07-01得票数 1
回答已采纳
Rebus具有灵活的系统，允许我在web.config中或通过实现自定义IDetermineMessageOwnership来为不同的消息类型指定不同的端点。
据我所知，消息所有权只由一个字符串表示。使用MSMQ传输，此字符串指向消息传递到的队列。使用RabbitMQ，字符串被用作消息的主题，然后将消息传递到名为"Rebus“的通用交换中。Rebus是个
浏览 3提问于2013-02-08得票数 3
回答已采纳
目前，我有一个IErrorHandler实现，用于处理进入Rebus错误队列的消息。然后，该处理程序将消息发布到saga，该saga限制到Slack通知通道的输出。不过，我认为可能有一种更简单的方法来做到这一点。我想让saga针对来自Rebus错误队列本身的消息实现一个IHandleMessages。这有可能吗？目前，我们已经启用了FleetManager进程，并且为了让我的自定义IErrorHandler能够工作，
浏览 20提问于2021-03-18得票数 0
我正在创建一个使用Rebus与Azure服务总线相关的概念的证明，但是我遇到了一个问题，即解析来自外部源的队列中的消息。我查看了GitHub，并注意到这个清单中有人是如何对RabbitMQ有类似问题的，建议使用装饰器：
var messageId
浏览 7提问于2016-12-06得票数 1
发生以下错误：
问题是，IResolutionContext需要注册自己的实现，而不是自己的IoC。IErrorHandler的名字似乎被过度使用了。我的要求是，给定两个独立的组件(
浏览 0提问于2019-05-31得票数 0
1回答
我正在考虑一种在Rebus中管理失败消息的方法。在我的第二级重试策略中，我希望将消息和异常详细信息保存到数据库中，以便稍后可以查看错误详细信息，并决定是将消息重新发送到要重新处理还是忽略并删除。to Defer Message with rebus_defer_count not shown
//Logic to save the message and err
浏览 0提问于2019-09-09得票数 2
1回答
我正面临着一个问题，我想使用Rebus来订阅和处理rabbitmq中的消息。在第三方程序集中定义了多种消息类型，新的消息类型将定期添加到该程序集中。我需要以某种方式使Rebus订阅并处理所有这些消息类型，并将它们转发(发布)到另一个rabbitmq实例。我的服务本质上是转发消息，并在这样做的时候添加一个自定义的rebus头。问题是，我不想为每种消息类型生成处理程序类(因为无论消息类型如何</
浏览 13提问于2020-09-14得票数 0
回答已采纳
在我的应用程序中，我尝试订阅“MyQueue”队列，该队列在“Rebus”主题交换中绑定到它，根据您的建议使用下一段代码： {.Declarations(false, false, false)
.ExchangeNames("RebusDirect", "Rebus如果我删除.Declarations(假的、假的、假的</
浏览 5提问于2016-07-27得票数 1
1回答
我们有一个Rebus消息处理程序，它可以与第三方webservice对话。由于无法控制的原因，WCF服务经常抛出异常，因为它在自己的数据库中遇到了数据库死锁。我们当前的配置使用了8个工作线程，但这只会使死锁情况变得更糟，因为webservice现在被并发调用，而消息会相互阻碍。
.Transport
浏览 0提问于2013-05-30得票数 2
回答已采纳
我想使用rebus实现下面的场景。我正在创建发送者应用程序和一个接收应用程序。如何做到这一点？Console.WriteLine("Press enter to quit"); } .Routing(r => r.TypeBased().Map<GetPersonResponse>("<e
浏览 4提问于2015-10-15得票数 4
回答已采纳
我正在尝试使用(外部)超时服务的Rebus。ContainerBuilder builder = new ContainerBuilder();
builder.RegisterAssemblyTypes”类型上找到的带有“公共绑定标志”的构
浏览 0提问于2015-02-01得票数 1
回答已采纳
我需要一种方法来发布消息到未知数量的订阅者。其中一个订阅者只能处理有限的负载，而一些消息只是更重要。优先处理高优先级的消息，等等。
我如何使用Rebus做到这一点呢？我想我需要每个订阅者三个队列？在哪里可以找到具有持久队列和MSMQ的发布/订阅示例？
浏览 2提问于2013-03-11得票数 3
回答已采纳
1回答
我正在尝试使用Rebus与Azure服务巴士和城堡温莎。当我使用我的代码版本而没有Castle时，队列和主题将被正确地创建：{ Console.ReadLine(); }..but当我
浏览 7提问于2020-02-27得票数 0
回答已采纳
我正在设置一个使用Rebus从RabbitMQ读取数据的.NET核心服务。似乎放在RabbitMQ中的请求需要具有.NET对象名称空间信息。有没有办法解决这个问题。例如，如果我有一个用Python编写的服务，将项放到队列中，那么是否可以读取和处理这些请求。似乎每次我测试并尝试发送.NET对象以外的内容时，都会得到一个异常。
浏览 12提问于2019-03-07得票数 1
1回答
可以在Entity Framework中使用用户定义函数(UDF)吗？是否可以通过存储过程使用它们，然后将它们添加到模型中？据我所知，只有当select存储过程返回一个实体时，才能通过函数导入使用它们--如果我错了，请纠正我;-)
浏览 1提问于2009-07-29得票数 4
回答已采纳
当我发送由AutoMapper.Mapper.DynamicMap()创建的实例时，我遇到一个错误，其中Rebus似乎希望为DynamicMap返回的代理类型确定端点。假设T是接口类型，此实例将包含T的实现。
是否有一种方法可以让Rebus为接口类型T而不是DynamicMap()返回的实现类型确定端点？我试着和IDetermineMessageOwnership玩了一圈，但到目前为止没有什么好运气。
浏览 5提问于2013-07-12得票数 3
根据要求，我被要求将信息导出到在MS CRM 4.0中创建的自定义实体中。我试图以编程的方式来实现这一点，但我还没有找到一段能够真正实现这一点的代码。我编写了代码来检查实体中是否存在某个字段的特定值，但创建一个新实体对我来说似乎有点令人费解。在这方面的任何帮助都将不胜感激。
浏览 1提问于2008-11-01得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
