You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by kg...@apache.org on 2011/04/28 20:39:00 UTC
svn commit: r1097571 -
/qpid/trunk/qpid/cpp/src/qpid/broker/QueueFlowLimit.cpp
Author: kgiusti
Date: Thu Apr 28 18:39:00 2011
New Revision: 1097571
URL: http://svn.apache.org/viewvc?rev=1097571&view=rev
Log:
QPID-3076: fix compilation for older version of boost library.
Modified:
qpid/trunk/qpid/cpp/src/qpid/broker/QueueFlowLimit.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/QueueFlowLimit.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/QueueFlowLimit.cpp?rev=1097571&r1=1097570&r2=1097571&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/QueueFlowLimit.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/QueueFlowLimit.cpp Thu Apr 28 18:39:00 2011
@@ -307,8 +307,8 @@ QueueFlowLimit *QueueFlowLimit::createLi
namespace {
/** pack a set of sequence number ranges into a framing::Array */
void buildSeqRangeArray(qpid::framing::Array *seqs,
- const qpid::framing::SequenceNumber first,
- const qpid::framing::SequenceNumber last)
+ const qpid::framing::SequenceNumber& first,
+ const qpid::framing::SequenceNumber& last)
{
seqs->push_back(qpid::framing::Array::ValuePtr(new Unsigned32Value(first)));
seqs->push_back(qpid::framing::Array::ValuePtr(new Unsigned32Value(last)));
@@ -329,7 +329,8 @@ void QueueFlowLimit::getState(qpid::fram
ss.add(itr->first);
}
framing::Array seqs(TYPE_CODE_UINT32);
- ss.for_each(boost::bind(&buildSeqRangeArray, &seqs, _1, _2));
+ typedef boost::function<void(framing::SequenceNumber, framing::SequenceNumber)> arrayBuilder;
+ ss.for_each((arrayBuilder)boost::bind(&buildSeqRangeArray, &seqs, _1, _2));
state.setArray("pendingMsgSeqs", seqs);
}
QPID_LOG(debug, "Queue \"" << queueName << "\": flow limit replicating pending msgs, range=" << ss);
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org