在rabbitmq中实现消息处理程序来处理接收到的消息

埃桑·阿克巴

最近我正在尝试使用 DDD 来实现我的应用程序。我使用 rabbitmq 代理来发布我的事件。假设我有 2 个域 AB。每个域都有它的 Database.i 想向 A 数据库添加一条记录,A 域应该发布一个事件以将该记录插入到 B 数据库中。

在实现中,当我在 A 数据库中插入记录时,我应该recordinserted从 A 域调用事件,但我的问题是我的 B 域应该如何调用messagehandler来处理该消息?我的意思是我应该调用一个线程来监听rabbitmq队列吗?

只是鲁

您可以自己实现消息处理,也可以使用服务总线。我有一个名为 Shuttle.Esb 的开源服务总线项目:

如果 Shuttle.Esb 没有引起您的共鸣,您还可以查看其他一些内容。

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章

RabbitMq以异步方式处理收到的消息

Android上的处理程序未收到消息

在 Twisted for Python 中处理接收到的消息的最佳方法是什么?

应用程序是否需要对在FCM中接收到和未发送delivery_receipt_request的消息进行不同的处理?

SOAP消息处理程序

Rabbitmq 处理消息后等待

Spring同时处理RabbitMQ消息

RabbitMQ:预取消息处理

Excel和RabbitMQ-在Excel中处理RabbitMQ消息吗?

客户未收到响应:“找不到消息类型的处理程序”

在PHPRatchet中接收RabbitMQ消息

在 apache camel 中使用 rabbitmq 来处理大文件/消息时减少内存使用

是否可以使方法(处理程序)从Spring Cloud Stream中的多个入站通道接收消息?

Python 中的 Websocket 消息处理程序

dbContext创建到消息处理程序中

在消息处理程序中添加属性值

无法在消息处理程序中写入文件

在MFC中处理消息

接收器如何处理QuickFIX / J中的消息

Websocketpp设置消息处理程序

Android处理程序不处理消息

Erlang多处理消息的接收和发送

KVO:已收到消息但未处理

如何在TkInter中实现“处理请求”消息

即使将动作处理程序放入“动作”对象中,我仍然在Emberjs中不断收到弃用消息

使用RabbitMQ的MassTransit 3.0.1(预发行版)无法使用与2.9.9相同的配置/设置来处理消息

在RabbitMQ中对接收到的消息进行分组,最好使用Spring AMQP?

处理前检查RabbitMQ消息序列

来自RabbitMQ的骆驼处理JSON消息