diff options
Diffstat (limited to 'qpid/cpp/src/qpid/messaging/amqp/ConnectionContext.cpp')
| -rw-r--r-- | qpid/cpp/src/qpid/messaging/amqp/ConnectionContext.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/qpid/cpp/src/qpid/messaging/amqp/ConnectionContext.cpp b/qpid/cpp/src/qpid/messaging/amqp/ConnectionContext.cpp index a16333b0bb..ce5a3d996f 100644 --- a/qpid/cpp/src/qpid/messaging/amqp/ConnectionContext.cpp +++ b/qpid/cpp/src/qpid/messaging/amqp/ConnectionContext.cpp @@ -141,12 +141,13 @@ void ConnectionContext::open() void ConnectionContext::run() { while (active.get()) { - pn_driver_wait(driver); + pn_driver_wait(driver, 0); for (pn_connector_t* c = pn_driver_connector(driver); c; c = pn_driver_connector(driver)) { ConnectionContext* context = reinterpret_cast<ConnectionContext*>(pn_connector_context(c)); qpid::sys::ScopedLock<qpid::sys::Monitor> l(context->lock); pn_connector_process(c); context->lock.notifyAll(); + pn_connector_process(c); } } } |