diff options
Diffstat (limited to 'cpp/src/qpid/client/Connector.cpp')
| -rw-r--r-- | cpp/src/qpid/client/Connector.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/cpp/src/qpid/client/Connector.cpp b/cpp/src/qpid/client/Connector.cpp index f32d0470ec..23d2c3ff8d 100644 --- a/cpp/src/qpid/client/Connector.cpp +++ b/cpp/src/qpid/client/Connector.cpp @@ -51,7 +51,8 @@ Connector::Connector( { } -Connector::~Connector(){ +Connector::~Connector() { + close(); if (receiver.id() && receiver.id() != Thread::current().id()) receiver.join(); } @@ -76,7 +77,6 @@ void Connector::init(){ receiver = Thread(this); } -// Call with closedLock held bool Connector::closeInternal() { Mutex::ScopedLock l(closedLock); if (!closed) { |