1 files changed, 1 insertions, 2 deletions
diff --git a/cpp/src/qpid/client/Dispatcher.cpp b/cpp/src/qpid/client/Dispatcher.cpp
index f4a7ff54d8..0783d5bc55 100644
--- a/cpp/src/qpid/client/Dispatcher.cpp
+++ b/cpp/src/qpid/client/Dispatcher.cpp
@@ -62,13 +62,12 @@ void Dispatcher::start()
 }
 
 void Dispatcher::run()
-{    
+{
     Mutex::ScopedLock l(lock);
     if (running) 
         throw Exception("Dispatcher is already running.");
     boost::state_saver<bool>  reset(running); // Reset to false on exit.
     running = true;
-    queue->open();
     try {
         while (!queue->isClosed()) {
             Mutex::ScopedUnlock u(lock);