问题标签 [nservicebus]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
nservicebus - NServiceBus - 消息发送到队列并从队列中删除,但从不触发 IHandleMessages.Handle
首先让我声明,今天是我使用 NSesrviceBus 的第一天——所以我希望我的问题不是太简单。
我已经成功地设置了 Sender、Receiver 和 Messages 项目。当我调试发件人时,我看到消息显示在配置的队列中。当我调试接收器时,消息会从队列中删除。但是,我的 IHandleMessages 句柄事件永远不会触发,并且不会显示控制台输出。
我确定我做错了什么(我想我可能混合了来自不同版本的 NServiceBus 的教程) - 任何建议都将不胜感激。
msmq - 带有大型 XML 消息的 nServiceBus
我已经阅读了真正的消息传递,它不是在总线上发送有效负载,而是发送一个标识符。在我们的案例中,我们有很多遗留应用程序/服务,它们旨在接收接近 4MB(接近 MSMQ 限制)的消息 (xml) 的有效负载。有没有办法让 nService 总线自动处理大负载和持久化消息或其他解决方法,以便发布者/订阅者服务不必担心负载大小,也不必担心如何去/重新水化有效载荷?先感谢您。
design-patterns - 命令查询分离验证重试
因此,我对 CQS 的基本概念感到满意,您可能有一个写入一个数据库的命令,并更新您从中读取的查询数据库。
但是,请考虑您正在输入数据并希望防止重复的情况。
以新员工数据录入员工登记为例,通过一堆申请表输入新员工的详细信息:
- 拿上表。
- 在 UI 中键入员工姓名和唯一工资单编号。
- 提交。
- 将纸张放入“完成的堆”中。
- 重复。
您现在如何防止用户再次输入相同的工资单号码,例如,如果他们分心并且不记得他们是否已经输入了一个并且“消息”还没有回到用户搜索的查询数据库?
nhibernate - 插入后nservicebus删除订阅记录?
我已经用 nservicebus 玩了几个星期了,由于我的本地机器上一切顺利,我决定尝试建立一个测试环境并进行部署。我正在使用 nservicebus 附带的通用主机,并且在本地运行时使用 nservicebus.Integration 配置文件,但想在测试环境中使用 Nservicebus.Production。我设置了一个 sql server 2008 数据库,对我的 app.config 进行了更改,一切似乎都运行良好。但是经过几次尝试,我注意到我的订阅者没有收到消息。我检查了订阅表,它是空的。检查日志后,我注意到以下内容:
2010-05-06 15:07:57,416 [1] 调试 NHibernate.Persister.Entity.AbstractEntityPers ister [(null)] <(null)> - 插入 0:插入 [订阅] (SubscriberEndpo int,MessageType) 值 (? , ?) 2010-05-06 15:07:57,416 [1] 调试 NHibernate.Persister.Entity.AbstractEntityPers ister [(null)] <(null)> - 更新 0:2010-05-06 15:07:57,416 [ 1] DEBUG NHibernate.Persister.Entity.AbstractEntityPers ister [(null)] <(null)> - 删除 0:从 [订阅] 哪里删除订阅者端点 = ?和消息类型 = ?
为什么它会在之后插入然后删除我的订阅?为了排除休眠方言问题,我尝试将订阅存储切换到 oracle 10g 数据库。它的行为完全相同,前 2 次有效,然后我开始看到我的订阅在插入后立即被删除。任何想法是什么导致了这种行为?
.net - 如何在网关模式下使用 NServiceBus
我一直试图让 NServiceBus 下载中的 pubsub 示例在网关模式下工作。
我还没有真正找到有关如何让 NServiceBus 在网关模式下运行的详细信息。
如何在网关模式下设置发布者/服务器?当我尝试时,我收到了一个拒绝访问异常,这可能是由于我正在运行它的帐户,或者我错过了一些东西。
如何设置订阅者/客户端以与网关通信?
谁能指出我正确的方向?
.net - NServiceBus 与 SQL Server 消息传输
有没有办法使用 SQL Server 作为物理消息传输,而不是使用 NServiceBus 的内置 MSMQ 消息传输?
谢谢
nservicebus - 启动 NServiceBus 端点时出现“未配置消息序列化程序”错误
我的 GenericHost 托管服务无法启动并显示以下消息:
2010-05-07 09:13:47,406 [1] FATAL NServiceBus.Host.Internal.GenericHost [(null)] <(null)> - System.InvalidOperationException:未配置消息序列化程序。在 NServiceBus.Unicast.Transport.Msmq.MsmqTransport.CheckConfiguration() 在 d:\BuildAgent-02\work\672d81652eaca4e1\src\impl\unicast\NServiceBus.Unicast.Msmq\ MsmqTransport.cs:line 241 在 NServiceBus.Unicast.Transport .Msmq.MsmqTransport.Start() 在 d:\BuildAgent-02\work\672d81652eaca4e1\src\impl\unicast\NServiceBus.Unicast.Msmq\MsmqTransport .cs:line 211 在 NServiceBus.Unicast.UnicastBus.NServiceBus.IStartableBus.Start (Action startupAction) in d:\BuildAgent-02\work\672d81652eaca4e1\src\unicast\NServiceBus.Uni cast\UnicastBus.cs: d 中 NServiceBus.Unicast.UnicastBus.NServiceBus.IStartableBus.Start() 的第 694 行:
我的端点配置如下所示:
我的 app.config 看起来像:
这在过去有效,但在通用主机启动时似乎失败了。下面是我的端点配置以及服务的 app.config。奇怪的是,在我的端点配置中,我指定使用 XmlSerializer 进行消息序列化。我在错误消息之前的控制台输出中看不到任何其他错误。我错过了什么?
谢谢,史蒂夫
.net - 在 nservicebus MSMQ 中达到 maxretries 时如何发送电子邮件
我有一个处理消息的 .net 服务。对于任何失败,我使用 log4net 并写入文件。我为此添加了一个 SMTP 附加程序。问题是我只想在出现问题时发送一封电子邮件。我的 app.config 中的 MaxRetries 设置为 5,这是正确的,log4net 文件中记录了 5 个错误,但也发送了 5 封电子邮件。
有什么方法可以让我处理最大重试次数并在达到时触发我的电子邮件?
谢谢你的帮助。
wcf - 派生类型的 Nservicebus 序列化问题
对于上下文设置,我在我的 nServiceBus 客户端和 nSerivceBus 服务器之间交换消息。它是命名空间 xyz.Messages 和一个类 Message : IMessage
我在其他 dll 中有更多消息,例如 xyz.Messages.Domain1、xyz.Messages.Domain2、xyz.Messages.Domain3。以及从基本消息 Message 派生的消息。
我将端点定义为:
在服务器
并且总线初始化为
现在,当我尝试发送消息类型的实例或任何类型的消息派生类型时,它成功地在服务器上发送消息,我得到了正确的类型。
例如。
当任何类型(例如 MessageDerived1)包含 Message 类型的成员变量时,我的问题就会出现,并且当我将其分配给派生类型时,该类型未通过网络正确传输。它仅作为消息类型传输,而不是派生类型。
非常感谢任何帮助。
谢谢TJ
nservicebus - NServiceBus 为某些消息类型指定 BinarySerializer,但不是为所有消息类型指定 BinarySerializer
NServiceBus 2.0 是否允许为给定的消息类型定义序列化程序?
我希望使用 XmlSerializer 对除我的一条消息之外的所有消息进行序列化。其余的应使用 BinarySerializer 进行序列化。
NServiceBus 2.0 可以吗?