我正要深入研究AMQP协议和其他东西。我正在使用质子与C绑定。
我在这里遇到了一个小问题。
比方说,我有一个异步接收器,就像它的例子一样,可以在simple_recv. cpp
中找到。所以,我在这里看到的问题是质子
有自己的主循环,与应用程序的主循环没有连接,如果接收应用程序即将处理一些标准输入
数据,这可能非常有用。因此,我的问题是:是否有可能(以及如何)处理来自标准输入
的数据,并且仍然使用异步质子-qpid
API。
我在这里看到的没有创建自己的反应器
或smth的唯一解决方案是使用多线程应用程序并尽可能支持线程安全。