diff options
Diffstat (limited to 'cpp/src/qpid/cluster/Connection.cpp')
| -rw-r--r-- | cpp/src/qpid/cluster/Connection.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/cpp/src/qpid/cluster/Connection.cpp b/cpp/src/qpid/cluster/Connection.cpp index 4f72501d52..3d5a7be1c3 100644 --- a/cpp/src/qpid/cluster/Connection.cpp +++ b/cpp/src/qpid/cluster/Connection.cpp @@ -585,9 +585,9 @@ void Connection::queuePosition(const string& qname, const SequenceNumber& positi findQueue(qname)->setPosition(position); } -void Connection::queueFairshareState(const std::string& qname, const framing::FieldTable& counts) +void Connection::queueFairshareState(const std::string& qname, const uint8_t priority, const uint8_t count) { - if (!qpid::broker::Fairshare::setState(findQueue(qname)->getMessages(), counts)) { + if (!qpid::broker::Fairshare::setState(findQueue(qname)->getMessages(), priority, count)) { QPID_LOG(error, "Failed to set fair share state on queue " << qname << "; this will result in inconsistencies."); } } |