问题标签 [flopsy]

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.

0 投票
1 回答
454 浏览

python - 在两个 RabbitMQ 队列中发布消息,而不是一个(使用 py-amqp)

我使用py-amqpFlopsy模块遇到了这个奇怪的问题。我编写了一个将消息发送到 RabbitMQ 服务器的发布者,我希望能够将其发送到指定的队列。在 Flopsy 模块上这是不可能的,所以我对其进行了调整,添加了一个参数和一行来在 Publisher 对象的 _init__ 方法上声明队列

通道对象是 py-amqplib 库的一部分

我遇到的问题是,即使它将消息发送到指定的队列,它也会将消息发送到默认队列。因为在这个系统中,我们希望发送相当多的消息,我们不想强调系统制造无用的重复......我试图调试代码并进入 py-amqplib 库,但我无法找出任何错误或缺少步骤。此外,我无法在代码之外找到任何文档形式的 py-amqplib。

关于为什么会发生这种情况以及如何纠正它的任何想法?

0 投票
1 回答
263 浏览

python - py-amqp/flopsy:在 Python 中等待单个 AMQP 消息

我有一个与此类似的问题在 py-amqp/flopsy 中很容易说“我将永远等待,并且我希望在收到消息时调用此回调”,但我找不到任何方式说“好的,我收到了我想要的消息,现在停止等待。” (也许是 GOTO?开个玩笑......)有没有一种优雅的方式来做到这一点?