2回答
我使用RabbitMq作为我的消息队列，并且我必须在我的应用程序中使用AMQP协议。我将消息发布到RabbitMq中的队列，并使用nodejs客户端使用这些消息。作为增强，我希望省略nodejs消费者客户端，并将其替换为WSO2 Data Service Server，因为目前nodejs客户端在从队列获取服务之后调用wso2-dss上托管的服务。我搜索了很多，但我找不到不
浏览 16提问于2016-08-16得票数 0
我们使用RabbitMQ作为消息代理。Producer1使用AMQP连接，Producer2使用STOMP协议连接，Consumer1使用AMQP连接，Consumer2 (使用javascript)通过websocket连接STOMP。(Producer1和consumer1使用春云流)
Test1:当producer1使用AMQP发送消息时，它在consumer1(AMQP)中
浏览 0提问于2017-09-27得票数 0
回答已采纳
我尝试用SpringIntegration和RabbitMQ编写示例生产者和消费者。在这里，我的rabbit.xml配置文件：<rabbit:template id="amqpTemplatethis.baseGateway.SendWait(callMethodMessage);
//this.baseGateway.FireForget(
浏览 5提问于2014-02-12得票数 0
回答已采纳
我正在使用Spring AMQP1.2版本对RabbitMQ broker进行性能测试。有人可以解释同样的步骤吗?我使用Java作为生产者和消费者的客户端。
浏览 0提问于2013-08-29得票数 0
1回答
我们在heroku上安装了一个应用程序，它使用celery来运行后台作业。芹菜应用程序使用RabbitMQ作为代理。我们使用heroku的AMQP附加组件作为RabbitMQ消息代理。这个附加组件指定了两个单独的url，一个为生产者优化，另一个为消费者优化。此外，根据RabbitMQ文档，建议对生产者和消费者使用单独的连接。Celery文档没有提供单独指定到生产者和消费者<
浏览 3提问于2013-11-07得票数 5
在Spring AMQP中，我们可以在消费者端设置超时吗？我们有一个AMQP消息到达消费者端的用例public class TestListener implements MessageListener {onMessage(Message message) { }
有没有办法让<e
浏览 23提问于2017-02-03得票数 0
我的生产者通过nodejs路由接收请求，并将它们发送给消费者，然后消费者通过从请求中接收的数据在数据库中创建一个文档。(req.body);});下面是我的生产者类import amqp from "amqplib/callback_apichannel.sendToQueue(queue, Buffer.from(message));
console.log("
浏览 18提问于2020-02-21得票数 0
1回答
使用Apache Camel amqp jms连接器。作为一名经纪人ActiveMQ。[AmqpProvider：(1)：amqp:HOST2 2]信息org.apache.qpid.jms.JmsConnection -连接ID：.：1连接到远程代理- SASL auth的最佳匹配是:SASL平原
[AmqpProvider：(2)：amqp:HOST2 2]信息org.a
浏览 0提问于2018-08-08得票数 1
我有一个同时支持amqp和openwire的activeMQ broker。openwire (tcp，端口61616)生产者有没有可能生成一个队列，该队列具有使用amqp协议的消费者？或者，我是否仅限于相同的协议消费者和生产者？
浏览 2提问于2015-03-02得票数 3
我使用的是来自linux的amqp消费者，以及来自Java项目的消息。我可以在linux使用者那里接收消息，但是我不知道如何确认这些消息是接收到的，并且还发送回响应。不可能吗？我已经使用了-A选项在amqp-消费者，但没有成功。amqp-consume -s 127.0.0.1:5672 -q myqueue -e "amq.topic" --vhost "/
浏览 2提问于2015-09-03得票数 1
回答已采纳
我是个推送通知的新手。我想写一个代码使用Spring AMQP将发送通知消息到APN。我随身带着.p12、认证和.pem文件。谁能帮我写代码使用Spring AMQP，它将发送通知消息。
提前谢谢。
浏览 3提问于2013-09-06得票数 0
初始状态: Rabbit有一个消费者连接到它结果:消费者试图重新连接Rabbit，但Rabbit的消费者列表中有消费者问:是否有机会自动检查消费者是否仍然可用，如果不是-将其从列表中删除？
请注意，心跳
浏览 1提问于2014-06-17得票数 0
使用Spring-AMQP抽象API，如何实现工作或任务队列？我只有一个生产者和多个工人消费者。消费者从队列中挑选下一项并对其进行处理。当您直接使用Spring时，这是受支持的，但我在RabbitMQ -AMQP中看不到任何支持。我是不是漏掉了什么？有没有其他实现工作队列的方法？
浏览 0提问于2015-04-17得票数 2
如果我们正在使用spring amqp client，它会自动禁用amqp客户端自动恢复属性，并使用自己的自动恢复mechanism.So如果我重新启动负载均衡器后面的群集节点之一，默认的spring“automatic”，"queue-master-locator":"random"，"queue-mode":"lazy"} 0
我们的消费者客户端运行在ECS上，有4个任
浏览 144提问于2019-07-31得票数 2
我对使用RabbitMQ作为消息队列协议非常陌生，我已经编写了RabbitMQ教程中给出的发送者和消费者工作队列的代码。当我们在发送者之前启动消费者时，上面的事情运行得很好。但是，如果我们在运行发送器之后启动消费者，就会出现问题。这些消息都不会被那些在运行发送器之后启动的消费者使用。在研究了RabbitMQ的架构和AMQP相关的东西之后，它似乎相当
浏览 0提问于2013-08-29得票数 1
我们使用的是spring-AMQP1.5.2，带有RabbitMQ版本3.5.3。所有队列都工作得很好，我们有消费者在监听它们，没有任何问题，除了一个消费者一直神秘地断开连接。spring-amqp自动恢复，但几个小时后，消费者断开连接，再也不会回来。使用者(监听器)被声明为public SimpleRabbitListenerContainerFactory analyzeTransactionListenerContainer
浏览 0提问于2016-02-23得票数 1
2回答
我编写了一个C(Rabbitmq)工作程序，它使用Python脚本(pika)发布的队列。
有什么
浏览 11提问于2014-08-01得票数 4
回答已采纳
13回答
总的来说，我刚刚开始使用RabbitMQ和AMQP。
我能让每个消费者收到相同的信息吗？
浏览 5提问于2012-05-16得票数 210
回答已采纳
1回答
我正在开发一个在Hapi框架中的node.js服务器。我采用RabbitMQ (amqp)来对任务进行排队。然而，一旦发送了请求，就不会立即回复请求，而是会向实际函数作为消费者所在的Rabbit服务器发送一条消息。然后，消费者应该将结果返回给(请求，回复)函数，并让该函数回复它。现在，我的解决方案是在我的worker文件( amqp使用者所在的位置)中创建一个变量并将其导出。然后，在索引文件(带有路
浏览 1提问于2017-02-23得票数 1
回答已采纳
我有一个要求，我必须听相同的交换，相同的队列，但不同的路线。 System.out.println("New message received" + message);}
这里的问题是，消息没有一致地到达正确的方法，例如: key1消息将传递给key2，反之亦然。如果有人需要额外的details.Appreciate，请提前告诉我
浏览 2提问于2017-02-07得票数 3
回答已采纳
云服务器
ICP备案
实时音视频
即时通信 IM
云直播
腾讯云开发者
