NserviceBus 属性注入
我正在尝试将一个对象注入到我的传奇中。使用以下端点,当消息到达 saga 的 handler 方法时,属性为 null。 端点: public class EndpointConfig : IC…
为什么启动服务时出现 CompletionMessage?
我创建了一个 nservice 应用程序。 应用程序监听队列A,如果队列A有消息则进行一些处理。 然后发送另一条消息到队列 B。 下面是我启动 nservice 总线…
WCF 中的 NServicebus 发布者
我想从 WCF 发布消息,我将其配置为: Bus = Configure.With(typeof(Messages).Assembly) .CustomConfigurationSource(new UserConfigurationSource(a…
NServiceBus 消息处理程序不会出现“错误”异常时排队
我有一个示例 NServiceBus 应用程序来测试水域。一切都很顺利,发送和处理工作正常。 我故意在某个消息处理程序中抛出异常来看看会发生什么 - 但什么…
NServiceBus 与自定义 NHibernate ConnectionProvider
问题: NSB 不会使用我们的自定义 NHB ConnectionProvider。 我使用以下设置在代码中配置 NSB(log4net 是 app.config 文件中的唯一内容): NService…
NServicebus 重试消息超过 MaxEntries 设置
即使我将 MaxRetries 设置为 1,如果出现错误,消息也会重试 N 次,例如 5 或 6 次。 这是一个错误吗? 是否可以禁用重试机制,以便在发生错误时消息…
NServicebus CastleWindsorBuilder 是否应该将总线注册到容器中
我有以下代码: public class MessageEndpoint : IConfigureThisEndpoint, AsA_Server, IWantCustomInitialization { private IWindsorContainer _con…
如何使用 Moq 测试对 NServiceBus IBus.Publish() 的调用?
以下代码编译、运行,完全符合我的预期 - 当事件引发时,GreetingPublisher 调用bus.Publish() - 但 Moq 设置不匹配: using Moq; using NServiceBus;…
没有 DTC 的 NServiceBus (AsA_Server) 是否可行?
我是第一次使用 NServiceBus,有一个小型、简单的应用程序,用户提交表单,然后将表单字段发送到队列,处理程序收集这些数据并使用 linq-to-sql 将其…
NServiceBus 是否适合跨平台集成?
如果您想将 .NET 应用程序与 Linux 上用 Python 甚至 php 等语言编写的其他应用程序集成,NServiceBus 是否适合? 当然,您必须将 MSMQ 替换为其他排…
如何解决与 NHibernateSagaPersister 的自动装配冲突?
我正在尝试连接我的第一个 Saga,但无法让接收端点正确处理启动消息。我得到以下异常: SagaMessageHandler 处理失败 信息。 Spring.Objects.Factory.…
NServiceBus 在订阅者订阅时发送信息
我刚刚开始使用 NServiceBus,并且已经启动并运行了一个非常基本的实现 - 非常类似于 PubSub 示例应用程序。 我想做的是当订阅者订阅时发送一些信息。…
NServiceBus Saga - 如何配置 millisToSleepBetweenMessages?
我是 C# 新手,我正在一个使用 NServiceBus Saga 的项目中工作。 在传奇的逻辑中,如果未满足条件,则将调用 RequestTimeout 方法 1 分钟。 问题是这…