diff options
| author | Gordon Sim <gsim@apache.org> | 2007-06-27 15:29:17 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2007-06-27 15:29:17 +0000 |
| commit | a5f95fd26f628f6ae45bd276505aaeb5177a1949 (patch) | |
| tree | bf0a7ccd30cabcca717ee14f6086a02bafc136e5 /qpid/cpp/src/tests/ExchangeTest.cpp | |
| parent | 576b4c0c1cfc411fd6ebe62b79d799477dc1910d (diff) | |
| download | qpid-python-a5f95fd26f628f6ae45bd276505aaeb5177a1949.tar.gz | |
Fixes and tests:
* ExchangeRegistry::get() caused a pair to be inserted with a 'null' pointer if the xchange didn't exist
* HeadersExchange::isBound() didn't check queue param
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@551197 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/tests/ExchangeTest.cpp')
| -rw-r--r-- | qpid/cpp/src/tests/ExchangeTest.cpp | 16 |
1 files changed, 16 insertions, 0 deletions
diff --git a/qpid/cpp/src/tests/ExchangeTest.cpp b/qpid/cpp/src/tests/ExchangeTest.cpp index 0033aa7529..595b025e86 100644 --- a/qpid/cpp/src/tests/ExchangeTest.cpp +++ b/qpid/cpp/src/tests/ExchangeTest.cpp @@ -19,10 +19,12 @@ * */ +#include "qpid/Exception.h" #include "qpid/broker/BrokerExchange.h" #include "qpid/broker/BrokerQueue.h" #include "qpid/broker/DeliverableMessage.h" #include "qpid/broker/DirectExchange.h" +#include "qpid/broker/ExchangeRegistry.h" #include "qpid/broker/FanOutExchange.h" #include "qpid/broker/HeadersExchange.h" #include "qpid/broker/TopicExchange.h" @@ -33,12 +35,14 @@ using namespace qpid::broker; using namespace qpid::framing; using namespace qpid::sys; +using namespace qpid; class ExchangeTest : public CppUnit::TestCase { CPPUNIT_TEST_SUITE(ExchangeTest); CPPUNIT_TEST(testMe); CPPUNIT_TEST(testIsBound); + CPPUNIT_TEST(testDeleteGetAndRedeclare); CPPUNIT_TEST_SUITE_END(); public: @@ -158,6 +162,18 @@ class ExchangeTest : public CppUnit::TestCase CPPUNIT_ASSERT(!headers.isBound(d, 0, &args2)); CPPUNIT_ASSERT(!headers.isBound(d, 0, &args3)); } + + void testDeleteGetAndRedeclare() { + ExchangeRegistry exchanges; + exchanges.declare("my-exchange", "direct", false, FieldTable()); + exchanges.destroy("my-exchange"); + try { + exchanges.get("my-exchange"); + } catch (const ChannelException&) {} + std::pair<Exchange::shared_ptr, bool> response = exchanges.declare("my-exchange", "direct", false, FieldTable()); + CPPUNIT_ASSERT_EQUAL(string("direct"), response.first->getType()); + + } }; // Make this test suite a plugin. |