问题标签 [rawrabbit]
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.
.net - RabbitMQ/C# 消息序列化
嘿,我在通过 newtonsoft 和 rabbitMQ 序列化我的 POCO 时遇到了一些问题,它们都实现了 IMessage 接口,但是 POCO 本身并不在应用程序之间共享,总而言之,我有一个 IMessage 接口和两个 Message : IMessage 类,每个项目一个,但是它们具有相同的结构,这就是为什么我想知道为什么 newtonsoft 不能序列化它们。
顺便说一句,我试图遵循一些人https://github.com/devmentors在这里开发的内容。
图案看起来像这样
pub 发布 UserCreated -> rabbitmq 总线 -> 订阅者接收 UserCreated 但 UserCreated 是两个不同的类,它们都实现了 IEvent 或其他一些标记接口
订户
和我的出版商
目前我收到此错误https://i.imgur.com/hvHiXWw.png
'JSON 中指定的类型'Acceptable.Message, Acceptable, Version=1.0.0.0, Culture=neutral, PublicKeyToken=null' 与'Not.Message, Not, Version=1.0.0.0, Culture=neutral, PublicKeyToken=null'不兼容'。路径'$type',第 1 行,位置 51。
而且我不知道为什么它们不兼容,它们都实现了 IMessage 并具有相同的道具。
rabbitmq - RawRabbit 的问题:自主发送各种消息
我不明白,我有一个自动发送各种消息的客户端,它不等待确认,但它必须发送它们,仅此而已,但似乎它只发送第一个消息,而只有当我发送所有其他消息时关闭应用程序。
我哪里错了?我应该设置什么?
更新:我使用的发送功能...
编辑:
在什么情况下会生成错误“Stage Initialized has no additional middlewares registered”?
我不明白为什么会在“SubscribeAsync”上生成此错误并且之后不发送消息。:(
请帮我。
json - RawRabbit - 如何发布/订阅 JSON 消息
我正在尝试做一些快速原型,使用 RabbitMQ 作为内部服务的消息代理以及网关通过 websocket 连接接收的来自外部客户端的消息。
我认为客户端将消息作为 json 发布,然后网关简单地向前发送未更改的 json 消息是最好的(并且可能只是)选项。
我已经看到 RawRabbit 能够将原始 Json 作为消息,然后将其反序列化为 C# 类。
我找不到一些关于流程应该是什么样子的示例和/或文档。也找不到有关如何格式化 Json 消息的文档。
xamarin - Xamarin + RabbitMq 本地主机连接问题
我在 Xamarin.Forms (android) + .Net 核心 API 中有移动应用程序。我们想出了如何通过使用 kestrel 和正确的启动设置(相同的 wifi 网络)通过本地托管的 API 调试移动请求。现在我无法访问本地 RabitMq 服务器。我使用 RawRabbit 包装器,因为它提供了漂亮且简单流畅的配置。当前配置:
例外只是超时。是否有可能允许通过整个本地网络访问此 Ip/端口?注意:我添加了防火墙规则以允许输入/输出端口 5672,结果相同。
提前感谢任何提示
c# - 如何添加自定义标头,然后在兔子消息标头中检索自定义标头
我需要找到一种方法在自定义标头中添加原始值,然后在兔子消息标头中检索自定义标头。理想情况下,我们应该这样。
到目前为止,我没有成功尝试找到一种方法来做到这一点。
.net-core - 配置 MassTransit 以使用 WebApplicationFactory 进行测试
我有一个 ASP.NET Core Web 应用程序和测试设置,WebApplicationFactory用于测试我的控制器操作。我以前使用过 RawRabbit,我很容易模拟IBusClient并将其作为单例添加到 DI 容器中。在WebApplicationFactory<TStartup>.CreateWebHostBuilder()我调用这个扩展方法来添加我的模拟IBusClient实例,就像这样;
但现在 RawRabbit 存在差距,这让我决定搬到 MassTransit。但是,我想知道是否已经有更好的方法可以将它注册IBus到我的容器中,而无需在我的测试中模拟它。不确定InMemoryTestFixture,BusTestFixture或BusTestHarness是否是我的问题的解决方案。不知道如何一起使用它们以及它们的作用。
顺便说一句,在我的 ASP.NET Core 应用程序中,我有一个可重用的扩展方法设置,如下面的代码,以便在启动时将我连接到 RabbitMQ。
c# - RawRabbit 发布消息
我如何发布和接收我尝试过的消息,如下面的代码,它使队列和交换,但没有消息进入我的应用程序?我做错了什么?