diff options
| author | Alan Conway <aconway@apache.org> | 2013-08-02 21:08:22 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2013-08-02 21:08:22 +0000 |
| commit | e139cb908acc36a6ef0ec86e99db939eb1206fc7 (patch) | |
| tree | d42430b2311c945b068e46be89c7601c52f050ad /cpp/src/qpid/ha/PrimaryTxObserver.cpp | |
| parent | 1ee8f335c83557211055bbfbefb17e8781d35e33 (diff) | |
| download | qpid-python-e139cb908acc36a6ef0ec86e99db939eb1206fc7.tar.gz | |
QPID-4327: HA Fix windows compile errors introduced by recent commits.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1509861 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/ha/PrimaryTxObserver.cpp')
| -rw-r--r-- | cpp/src/qpid/ha/PrimaryTxObserver.cpp | 13 |
1 files changed, 6 insertions, 7 deletions
diff --git a/cpp/src/qpid/ha/PrimaryTxObserver.cpp b/cpp/src/qpid/ha/PrimaryTxObserver.cpp index b63a40234e..d30fa06caa 100644 --- a/cpp/src/qpid/ha/PrimaryTxObserver.cpp +++ b/cpp/src/qpid/ha/PrimaryTxObserver.cpp @@ -40,7 +40,6 @@ class FieldTable; namespace ha { using namespace std; -using namespace boost; using namespace qpid::broker; using namespace qpid::framing; @@ -70,7 +69,7 @@ class PrimaryTxObserver::Exchange : public broker::Exchange { private: static const string TYPE_NAME; - typedef function<void(const std::string&)> DispatchFn; + typedef boost::function<void(const std::string&)> DispatchFn; typedef qpid::sys::unordered_map<std::string, DispatchFn> DispatchMap; DispatchMap dispatch; @@ -89,11 +88,11 @@ PrimaryTxObserver::PrimaryTxObserver(HaBroker& hb) : // when the tx-queue is deleted. // BrokerInfo::Set infoSet(haBroker.getMembership().otherBackups()); - transform(infoSet.begin(), infoSet.end(), inserter(backups, backups.begin()), - bind(&BrokerInfo::getSystemId, _1)); + std::transform(infoSet.begin(), infoSet.end(), inserter(backups, backups.begin()), + boost::bind(&BrokerInfo::getSystemId, _1)); QPID_LOG(debug, logPrefix << "Started on " << backups); - pair<shared_ptr<Queue>, bool> result = + pair<QueuePtr, bool> result = broker.getQueues().declare( TRANSACTION_REPLICATOR_PREFIX+id.str(), QueueSettings(/*durable*/false, /*autodelete*/true)); @@ -102,7 +101,7 @@ PrimaryTxObserver::PrimaryTxObserver(HaBroker& hb) : } void PrimaryTxObserver::initialize() { - broker.getExchanges().registerExchange(make_shared<Exchange>(shared_from_this())); + broker.getExchanges().registerExchange(boost::make_shared<Exchange>(shared_from_this())); } void PrimaryTxObserver::enqueue(const QueuePtr& q, const broker::Message& m) @@ -123,7 +122,7 @@ void PrimaryTxObserver::dequeue( } void PrimaryTxObserver::deduplicate(sys::Mutex::ScopedLock&) { - shared_ptr<Primary> primary(boost::dynamic_pointer_cast<Primary>(haBroker.getRole())); + boost::shared_ptr<Primary> primary(boost::dynamic_pointer_cast<Primary>(haBroker.getRole())); assert(primary); // Tell replicating subscriptions to skip IDs in the transaction. for (UuidSet::iterator b = backups.begin(); b != backups.end(); ++b) |
