带标准输入的 Proton QPID
Proton QPID with standard input
我正要深入研究 AMQP 协议和其他东西。我正在使用 proton 和 C++ 绑定。
我在这里遇到了一个小问题。
说，我有一个异步接收器，就像它的示例一样，可以在 simple_recv.cpp 中找到。所以，我在这里看到的问题是 proton 有它自己的主循环，没有与应用程序的主循环连接，如果接收应用程序即将处理一些 stdin 数据，这可能非常有用。
因此我的问题是：是否有可能（以及如何）处理来自 stdin 的数据并仍然使用异步 proton-qpid API.
我看到没有创建自己的 reactor 或类似 here 的唯一解决方案是使用多线程应用程序并尽可能支持线程安全。
我正要深入研究 AMQP 协议和其他东西。我正在使用 proton 和 C++ 绑定。
我在这里遇到了一个小问题。
说，我有一个异步接收器，就像它的示例一样，可以在 simple_recv.cpp 中找到。所以，我在这里看到的问题是 proton 有它自己的主循环，没有与应用程序的主循环连接，如果接收应用程序即将处理一些 stdin 数据，这可能非常有用。
因此我的问题是：是否有可能（以及如何）处理来自 stdin 的数据并仍然使用异步 proton-qpid API.
我看到没有创建自己的 reactor 或类似 here 的唯一解决方案是使用多线程应用程序并尽可能支持线程安全。