sockjs-cycloneメッセージをRabbitMQにプッシュするさまざまなアプリケーションがあり、サーバーがそれらのメッセージを消費してWebSocketクライアントにプッシュしたいと考えています。kombuRabbitMQ コンシューマ ライブラリとして使用したいのですが、コンシューマをどこに置くべきか、kombu'sコンシューマ インターフェイスのどの部分を使用すればよいかわかりません。
私は、少なくとも次の精神的障害に悩まされています。
SockJSConnectionアクセスできるように、明らかに内部から消費する必要がありますself.sendMessage- しかし、これらは同期のブロッキング呼び出しであるため、どこからでも
kombu'sConnection.drain_eventsorを使用できるとは思いません。SimpleQueue.get
これら 2 つのライブラリを統合する良い方法はありますか?