如何将kombu消费者与sockjscyclone一起使用?

2024-04-26 19:12:59 发布

您现在位置:Python中文网/ 问答频道 /正文

我有各种应用程序将消息推送到RabbitMQ中,我希望我的sockjs-cyclone服务器使用这些消息并将它们推送到websocket客户端。我想使用kombu作为我的RabbitMQ使用者库,但是我不知道应该将我的使用者放在哪里以及应该使用kombu's使用者接口的哪些部分。你知道吗

我至少有以下心理障碍:

  • 我显然需要从我的SockJSConnection内部消费,这样我就可以访问self.sendMessage
  • 但我不认为我可以在任何地方使用kombu'sConnection.drain_eventsSimpleQueue.get,因为这些都是同步的阻塞调用。你知道吗

有没有一个好的方法来整合这两个库?你知道吗


Tags: self服务器应用程序消息客户端地方rabbitmq使用者