1

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

我至少陷入了以下精神障碍：

  • 我显然需要从我的内部消费，SockJSConnection以便我可以访问self.sendMessage
  • 但我不认为我可以使用kombu's Connection.drain_events或SimpleQueue.get从那里的任何地方使用，因为这些是同步的阻塞调用。

有没有整合这两个库的好方法？

4

0 回答 0