rebus

    1热度

    1回答

    延长路由的配置我有一个画谜配置项目这是许多Web API项目 所以基本上共享,它看起来像 的Web API 1 ==>共享Rebus的配置 网络API 2 ==>共享Rebus的配置 的Web API 3 ==>共享卤面配置 我的问题是,如果我有一些消息在网络API 3项目&处理,我怎么可以配置为他们的路由? 我目前的配置: var autofacContainerAdapter = new Au

    1热度

    1回答

    重试的消息,我能够写一个自定义的重试政策,使用SQL Server为递延消息存储。但是现在,为了可扩展性的原因,我想运行多个部署在不同机器上的工作人员(消息处理程序任务)。由于这个原因,我希望有一个中心位置来读取延迟消息(如从队列中读取),而不是从sql server读取数据。 有什么办法来存储在队列中的延迟的消息?这是更好的方法吗?这样做会更好吗?

    1热度

    1回答

    为什么当我通过画谜,它被添加像下面额外的对象数据,主要是$类型将消息发送到RabbitMQ的。 {"$type":"ThreeSquared.VTGPAM.Objects.Wagon, ThreeSquared.VTGPAM.Objects","WagonId":"a98a06ab-33b9-4a11-9de2-df0b8787b713","WamosId":12324,"Description"

    1热度

    1回答

    我想获取与RabbitMQ的rebus来检索已成功发布到消息队列的消息。我没有做的事情需要完成。下面是示例代码? static async Task MainSubscribeAsync() { var connection = "amqp://jhgj67546:[email protected]"; using (var activator = ne

    1热度

    1回答

    我无法检索对象,一旦我将它添加到队列中,添加它的代码如下所示,这工作正常,据我所知,因为得到的消息在队列。 var connection = "amqp://name:[email protected]"; using (var activator = new BuiltinHandlerActivator()) { Configure.With(activator) .

    1热度

    3回答

    方案:使用多个卫星库 的.NET Framework 4.6 简单的注射器 卤面 Rebus.AzureServiceBus 卤面 的Web API应用程序。简单的喷油器 在我的应用程序中有多个卫星库,其中大多数都有一个实现SimpleInjector接口的类,即将容器注册分组到不同库中。这些软件包获得注册在启动时 container.RegisterPackages(AppDomain.Curr

    1热度

    1回答

    我使用的是Simpleinjector的Rebus 3.0.1。我已经注册了一个装饰,日志记录,所有的处理程序,这种方式: container.RegisterDecorator(typeof(IHandleMessages<>), typeof(HandlerLogDecorator<>)); 一切工作正常,除了传奇故事:因为在LoadSagaDataStep,下面的代码 var han

    -1热度

    1回答

    我有一个现有的系统,通过MassTransit发布消息到一些Azure服务总线主题名为CompanyName.SystemName.Messages.SomethingGotUpdated。如何使用Rebus配置新系统作为该特定主题的订阅者,然后将所有消息发送到相应的IHandleMessages<SomethingGotUpdated>处理程序? 我查看了文档,但无法真正弄清楚如何完成此操作。任

    1热度

    3回答

    我在尝试中止消息处理程序中的事务时很挣扎。我正在使用RabbitMQ。 我的目标是具有以下行为:如果收到消息,我尝试将其内容存储在硬盘上。如果失败了,我想重新输入邮件。通过这样做,我给同一服务的另一个实例提供了尝试相同的机会。 我想要的基本上是控制消息何时被编辑或拒绝的可能性。 我已经查看了源代码,特别是RabbitMqTransport.cs,发现当交易提交时发送了一个ACK。如果交易被中止,则

    1热度

    1回答

    我有一个场景,我在我的一个处理程序中调用api,并且Api可以每个月减少6小时。因此,我设计了1秒重试,1分钟重试和6小时重试的重试逻辑。这一切工作正常,但后来我发现长时间延迟重试不是一个好的选择。请给我你的经验吗? 谢谢!