我使用RabbitMq作为我的消息队列,并且我必须在我的应用程序中使用AMQP协议。我将消息发布到RabbitMq中的队列,并使用nodejs客户端使用这些消息。作为增强,我希望省略nodejs消费者客户端,并将其替换为WSO2 Data Service Server,因为目前nodejs客户端在从队列获取服务之后调用wso2-dss上托管的服务。
应用程序概述:可以创建多个动态队列。每个队列应该只有一个消费者。只有当消费者完成对一条消息的处理时,消费者才应该拿起另一条消息。,我都会将详细信息发送到以target分支命名的队列中的rabbitMQ,这样所有的拉取请求都会在队列中得到验证,并且我会像这样创建一个消费者。new ConsumerHandler(), new Jackson2JsonMessageConverter()));