diff --git a/LCS/MessageBus/include/MessageBus/MsgBus.h b/LCS/MessageBus/include/MessageBus/MsgBus.h
index 223ef09a575eb1faddd7e9f3a7fca1eccb1c7376..8a6a30ff2b10f1f1132c8b5293de98ffe1074780 100644
--- a/LCS/MessageBus/include/MessageBus/MsgBus.h
+++ b/LCS/MessageBus/include/MessageBus/MsgBus.h
@@ -56,7 +56,7 @@ public:
 
   void ack(qpid::messaging::Message &msg);
   void reject(qpid::messaging::Message &msg);
-  void addQueue(const std::string &address="testqueue", const std::string &options="; {create: always}");
+  bool addQueue(const std::string &address="testqueue", const std::string &options="; {create: always}");
 };
 
 class ToBus
@@ -72,5 +72,6 @@ public:
   void send(const std::string &msg);
 };
 #endif
+}
 #endif
 
diff --git a/LCS/MessageBus/src/MsgBus.cc b/LCS/MessageBus/src/MsgBus.cc
index 7cda238d52ec57a75b706ac700454314b46aedd2..4e45507b4272e9a21db9a19b11d27bb12bc5454d 100644
--- a/LCS/MessageBus/src/MsgBus.cc
+++ b/LCS/MessageBus/src/MsgBus.cc
@@ -1,12 +1,12 @@
 #include "lofar_config.h"
 
 #include <MessageBus/MsgBus.h>
-#include <Common/LofarLogger.h>
+//#include <Common/LofarLogger.h>
 
 #ifdef HAVE_QPID
 #include <qpid/types/Exception.h>
 #include <qpid/messaging/exceptions.h>
-#include <qpid/messaging/Logger.h>
+//#include <qpid/messaging/Logger.h>
 
 using namespace qpid::messaging;
 
@@ -38,14 +38,14 @@ namespace LOFAR {
  
   FromBus::~FromBus(void)
   {
-    if (itsNrMissingACKs)
-      LOG_ERROR_STR("Queue " << itsQueueName << " on broker " << itsBrokerName << " has " << itsNrMissingACKs << " messages not ACK'ed ");
+//    if (itsNrMissingACKs)
+//      LOG_ERROR_STR("Queue " << itsQueueName << " on broker " << itsBrokerName << " has " << itsNrMissingACKs << " messages not ACK'ed ");
   }
 
   bool FromBus::getMessage(Message &msg, double timeout) // timeout 0.0 means blocking
   {
     Receiver next;
-    if (session.nextReceiver(next,TimeOutDuration(timeout)))
+    if (itsSession.nextReceiver(next,TimeOutDuration(timeout)))
     {
         itsNrMissingACKs++;
         return next.get(msg);
@@ -91,7 +91,7 @@ namespace LOFAR {
      itsConnection.open();
      itsSession = itsConnection.createSession();
      Address addr(address+options);
-     sender = itsSession.createSender(addr);
+     Sender itsSender = itsSession.createSender(addr);
   } catch(const qpid::types::Exception &ex) {
     THROW(MessageBusException, ex.what());
   }
@@ -102,9 +102,9 @@ namespace LOFAR {
   void ToBus::send(const std::string &msg)
   {
     Message tosend(msg);
-    sender.send(tosend,true);
+    itsSender.send(tosend,true);
   }
 
 } // namespace LOFAR
 
-#endif
\ No newline at end of file
+#endif