AMQP-CPP >处理程序中的错误文件描述符

我正在尝试使用 AMQP-CPP 库进行消息传递，但我无法使其工作。我想将库中已经构建的类用于通道、连接、处理程序。我从他们的例子开始，但每次运行代码时Bad file descriptor我都会收到错误并且进程结束。我的代码看起来像这样

#include <amqpcpp.h>
#include <amqpcpp/libboostasio.h>
#include <boost/asio/io_service.hpp>
#include <boost/asio/strand.hpp>
#include <boost/asio/deadline_timer.hpp>
class MyHandler : public AMQP::LibBoostAsioHandler
{
public:
MyHandler(boost::asio::io_service& service)
: AMQP::LibBoostAsioHandler(service)
{
}
virtual void onError(AMQP::TcpConnection *connection, const char *message) override
{
std::cout << "MyHandler::onError " << message << std::endl;
}
};
int main()
{
// access to the event loop
boost::asio::io_service service(2);
// handler for libevent
MyHandler handler(service);
// make a connection
AMQP::TcpConnection connection(&handler, AMQP::Address("amqp://localhost/"));
// we need a channel too
AMQP::TcpChannel channel(&connection);
channel.onError([](const char *message) {
// report error
std::cout << "channel error: " << message << std::endl;
});
channel.onReady([]() {
// send the first instructions (like publishing messages)
std::cout << "channel onReady: " << std::endl;
});
// create a temporary queue
channel.declareQueue("aaa").onSuccess([&connection](const std::string& name, uint32_t messagecount, uint32_t consumercount) {
// report the name of the temporary queue
std::cout << "declared queue " << name << std::endl;
// now we can close the connection
connection.close();
});  
auto startCb = [](const std::string &consumertag) {
std::cout << "consume operation started" << std::endl;
};
// callback function that is called when the consume operation failed
auto errorCb = [](const char *message) {
std::cout << "consume operation failed" << std::endl;
};
// callback operation when a message was received
auto messageCb = [&channel](const AMQP::Message &message, uint64_t deliveryTag, bool redelivered) {
std::cout << "message received" << std::endl;
// acknowledge the message
channel.ack(deliveryTag);
};
channel.consume("aaa").onReceived(messageCb)
.onSuccess(startCb)
.onError(errorCb);
// run the loop
service.run();
return 0;
}

输出：

MyHandler：：onError 错误的文件描述符

此外，线路上也发生错误service.run();

我也用libevent尝试过类似的事情。

这里出了什么问题以及如何解决？有什么想法吗？