diff options
Diffstat (limited to 'cpp/src/qpid/messaging/FailoverUpdates.cpp')
-rw-r--r-- | cpp/src/qpid/messaging/FailoverUpdates.cpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/cpp/src/qpid/messaging/FailoverUpdates.cpp b/cpp/src/qpid/messaging/FailoverUpdates.cpp index 27b94aaa7a..4f2fcf2e82 100644 --- a/cpp/src/qpid/messaging/FailoverUpdates.cpp +++ b/cpp/src/qpid/messaging/FailoverUpdates.cpp @@ -28,10 +28,12 @@ #include "qpid/log/Statement.h" #include "qpid/Exception.h" #include "qpid/Url.h" +#include "qpid/framing/Uuid.h" #include <vector> namespace qpid { namespace messaging { +using framing::Uuid; struct FailoverUpdatesImpl : qpid::sys::Runnable { @@ -42,7 +44,7 @@ struct FailoverUpdatesImpl : qpid::sys::Runnable FailoverUpdatesImpl(Connection& c) : connection(c) { - session = connection.createSession("failover-updates"); + session = connection.createSession("failover-updates."+Uuid(true).str()); receiver = session.createReceiver("amq.failover"); thread = qpid::sys::Thread(*this); } |