summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/cluster/FailoverExchange.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/cluster/FailoverExchange.cpp')
-rw-r--r--cpp/src/qpid/cluster/FailoverExchange.cpp5
1 files changed, 2 insertions, 3 deletions
diff --git a/cpp/src/qpid/cluster/FailoverExchange.cpp b/cpp/src/qpid/cluster/FailoverExchange.cpp
index cfbe34a460..43ec27cf2c 100644
--- a/cpp/src/qpid/cluster/FailoverExchange.cpp
+++ b/cpp/src/qpid/cluster/FailoverExchange.cpp
@@ -28,6 +28,7 @@
#include "qpid/framing/MessageTransferBody.h"
#include "qpid/log/Statement.h"
#include "qpid/framing/Array.h"
+#include "qpid/UrlArray.h"
#include <boost/bind.hpp>
#include <algorithm>
@@ -86,9 +87,7 @@ void FailoverExchange::route(Deliverable&, const string& , const framing::FieldT
void FailoverExchange::sendUpdate(const Queue::shared_ptr& queue) {
// Called with lock held.
if (urls.empty()) return;
- framing::Array array(0x95);
- for (Urls::const_iterator i = urls.begin(); i != urls.end(); ++i)
- array.add(boost::shared_ptr<Str16Value>(new Str16Value(i->str())));
+ framing::Array array = vectorToUrlArray(urls);
const ProtocolVersion v;
boost::intrusive_ptr<Message> msg(new Message);
AMQFrame command(MessageTransferBody(v, typeName, 1, 0));