Tag: cloudamqp

处理node-amqp（node.js）中的独占队列订阅时出错

当您订阅独占队列（一次只允许一个消费者）时，node-amqp会在队列超额订阅（已经有消费者）时抛出exception。 我试过使用.on（“error”，cb）语法。 我试过错误域（节点0.10.0） 尝试/抓住显然没有工作 这是我的订阅线，但没什么特别的： queue.subscribe({ack: true, prefetchCount: 1, exclusive: exclusive}, cbExecute).addCallback((ok) -> listeners[type] = ok.consumerTag); 当使用队列时，会得到未处理的exception： ACCESS_REFUSED – queue 'respQ' in vhost 'brkoacph' in exclusive use 看看node-amqp里面的内容，我发现它们在模块内部实现了一个独立的任务队列，所以当发生错误时，任务在独立的上下文中运行。 有没有解决方法？ …或者我只是做错了什么？

无法从云AMQP队列中获取消息

嗨，我想在我的帆应用程序中使用rabbitmq。 当我试图发布数据后，我的模型给连接适配器我可以看到我的兔子队列中收到的数据，但数据库尚未创build。 我使用mongo数据库作为我的模型，sails-rabbitmq作为我的node_module我引用了这个链接 npm install sails-rabbitmq 连接适配器是 – rabbitCluster: { adapter: 'sails-rabbitmq', //my amqp rabbitmq installation url url: 'amqp://localhost', }, MongoDB: { adapter: 'sails-mongo', host: 'localhost', port: 27017, user: '', password: '', database: 'myTest' } 在我的模型里面指定了连接如下 connection : ['rabbitCluster','MongoDB'] //in my config/rabbitmq.js file module.exports.rabbitmq = { pkFormat: 'string' }; 据我所知，我们不需要编写创build和更新控制器方法，它应该与sails提供的默认CRUD操作。 但是当我尝试创build数据库条目时，我没有得到任何回应。