summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/messaging/FailoverUpdates.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/messaging/FailoverUpdates.cpp')
-rw-r--r--cpp/src/qpid/messaging/FailoverUpdates.cpp4
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);
}