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