我有各种应用程序将消息推送到RabbitMQ中,我希望我的sockjs-cyclone
服务器使用这些消息并将它们推送到websocket客户端。我想使用kombu
作为我的RabbitMQ使用者库,但是我不知道应该将我的使用者放在哪里以及应该使用kombu's
使用者接口的哪些部分。你知道吗
我至少有以下心理障碍:
SockJSConnection
内部消费,这样我就可以访问self.sendMessage
kombu's
Connection.drain_events
或SimpleQueue.get
,因为这些都是同步的阻塞调用。你知道吗有没有一个好的方法来整合这两个库?你知道吗
目前没有回答
相关问题 更多 >
编程相关推荐