[rhmessaging-commits] rhmessaging commits: r4514 - in store/trunk/cpp: tests/cluster and 1 other directory.

Author: aconway Date: 2012-09-25 16:44:25 -0400 (Tue, 25 Sep 2012) New Revision: 4514 Modified: store/trunk/cpp/lib/MessageStoreImpl.cpp store/trunk/cpp/tests/cluster/run_ha_tests Log: Added logging for recovery of exchanges and bindings. Modified: store/trunk/cpp/lib/MessageStoreImpl.cpp =================================================================== --- store/trunk/cpp/lib/MessageStoreImpl.cpp 2012-09-25 14:06:36 UTC (rev 4513) +++ store/trunk/cpp/lib/MessageStoreImpl.cpp 2012-09-25 20:44:25 UTC (rev 4514) @@ -862,6 +862,7 @@ //set the persistenceId and update max as required exchange->setPersistenceId(key.id); index[key.id] = exchange; + QPID_LOG(info, "Recovered exchange \"" << exchange->getName() << '"'); } maxExchangeId = std::max(key.id, maxExchangeId); } @@ -895,6 +896,9 @@ if (exchange != exchanges.end() && queue != queues.end()) { //could use the recoverable queue here rather than the name... exchange->second->bind(queueName, routingkey, args); + QPID_LOG(info, "Recovered binding exchange=" << exchange->second->getName() + << " key=" << routingkey + << " queue=" << queueName); } else { //stale binding, delete it QPID_LOG(warning, "Deleting stale binding"); Modified: store/trunk/cpp/tests/cluster/run_ha_tests =================================================================== --- store/trunk/cpp/tests/cluster/run_ha_tests 2012-09-25 14:06:36 UTC (rev 4513) +++ store/trunk/cpp/tests/cluster/run_ha_tests 2012-09-25 20:44:25 UTC (rev 4514) @@ -27,4 +27,4 @@ export STORE_LIB="${abs_builddir}/../../lib/.libs/msgstore.so" TEST=ha_store_tests.py which $TEST > /dev/null || { echo "Skip ha tests, $TEST not found"; exit 0; } -exec $TEST +exec $TEST $HA_TESTS